public class VersionOneProtocolChannelReceiver extends Object implements org.jboss.remoting3.Channel.Receiver, DeploymentRepositoryListener, RegistryCollector.Listener<String,List<org.jboss.as.network.ClientMapping>>, org.jboss.as.server.suspend.ServerActivity
Modifier and Type | Field and Description |
---|---|
protected ChannelAssociation |
channelAssociation |
protected RegistryCollector<String,List<org.jboss.as.network.ClientMapping>> |
clientMappingRegistryCollector |
protected Set<org.jboss.as.ejb3.remote.protocol.versionone.VersionOneProtocolChannelReceiver.ClusterTopologyUpdateListener> |
clusterTopologyUpdateListeners |
protected DeploymentRepository |
deploymentRepository |
protected ExecutorService |
executorService |
protected org.jboss.marshalling.MarshallerFactory |
marshallerFactory |
protected RemoteAsyncInvocationCancelStatusService |
remoteAsyncInvocationCancelStatus |
protected org.jboss.as.server.suspend.SuspendController |
suspendController |
protected EJBRemoteTransactionsRepository |
transactionsRepository |
Constructor and Description |
---|
VersionOneProtocolChannelReceiver(ChannelAssociation channelAssociation,
DeploymentRepository deploymentRepository,
EJBRemoteTransactionsRepository transactionsRepository,
RegistryCollector<String,List<org.jboss.as.network.ClientMapping>> clientMappingRegistryCollector,
org.jboss.marshalling.MarshallerFactory marshallerFactory,
ExecutorService executorService,
RemoteAsyncInvocationCancelStatusService asyncInvocationCancelStatusService,
org.jboss.as.server.suspend.SuspendController suspendController) |
Modifier and Type | Method and Description |
---|---|
void |
deploymentAvailable(DeploymentModuleIdentifier deploymentModuleIdentifier,
ModuleDeployment moduleDeployment)
Callback when a deployment becomes available
|
void |
deploymentRemoved(DeploymentModuleIdentifier deploymentModuleIdentifier)
Called when a deployment is no longer available
|
void |
deploymentStarted(DeploymentModuleIdentifier deploymentModuleIdentifier,
ModuleDeployment moduleDeployment)
Callback when a deployment has started, i.e.
|
protected MessageHandler |
getMessageHandler(byte header)
Returns a
MessageHandler which can handle a message represented by the passed header . |
void |
handleEnd(org.jboss.remoting3.Channel channel) |
void |
handleError(org.jboss.remoting3.Channel channel,
IOException error) |
void |
handleMessage(org.jboss.remoting3.Channel channel,
org.jboss.remoting3.MessageInputStream messageInputStream) |
void |
listenerAdded(DeploymentRepository repository)
Called when the listener is added to the repository.
|
void |
preSuspend(org.jboss.as.server.suspend.ServerActivityCallback listener) |
protected void |
processMessage(org.jboss.remoting3.Channel channel,
InputStream inputStream) |
void |
registryAdded(Registry<String,List<org.jboss.as.network.ClientMapping>> cluster) |
void |
registryRemoved(Registry<String,List<org.jboss.as.network.ClientMapping>> registry) |
void |
resume() |
void |
startReceiving() |
void |
suspended(org.jboss.as.server.suspend.ServerActivityCallback listener) |
protected final ChannelAssociation channelAssociation
protected final DeploymentRepository deploymentRepository
protected final EJBRemoteTransactionsRepository transactionsRepository
protected final org.jboss.marshalling.MarshallerFactory marshallerFactory
protected final ExecutorService executorService
protected final RegistryCollector<String,List<org.jboss.as.network.ClientMapping>> clientMappingRegistryCollector
protected final Set<org.jboss.as.ejb3.remote.protocol.versionone.VersionOneProtocolChannelReceiver.ClusterTopologyUpdateListener> clusterTopologyUpdateListeners
protected final RemoteAsyncInvocationCancelStatusService remoteAsyncInvocationCancelStatus
protected final org.jboss.as.server.suspend.SuspendController suspendController
public VersionOneProtocolChannelReceiver(ChannelAssociation channelAssociation, DeploymentRepository deploymentRepository, EJBRemoteTransactionsRepository transactionsRepository, RegistryCollector<String,List<org.jboss.as.network.ClientMapping>> clientMappingRegistryCollector, org.jboss.marshalling.MarshallerFactory marshallerFactory, ExecutorService executorService, RemoteAsyncInvocationCancelStatusService asyncInvocationCancelStatusService, org.jboss.as.server.suspend.SuspendController suspendController)
public void startReceiving()
public void handleError(org.jboss.remoting3.Channel channel, IOException error)
handleError
in interface org.jboss.remoting3.Channel.Receiver
public void handleEnd(org.jboss.remoting3.Channel channel)
handleEnd
in interface org.jboss.remoting3.Channel.Receiver
public void handleMessage(org.jboss.remoting3.Channel channel, org.jboss.remoting3.MessageInputStream messageInputStream)
handleMessage
in interface org.jboss.remoting3.Channel.Receiver
protected MessageHandler getMessageHandler(byte header)
MessageHandler
which can handle a message represented by the passed header
. Returns null if there's no such MessageHandler
header
- The message headerprotected void processMessage(org.jboss.remoting3.Channel channel, InputStream inputStream) throws IOException
IOException
public void listenerAdded(DeploymentRepository repository)
DeploymentRepositoryListener
listenerAdded
in interface DeploymentRepositoryListener
public void deploymentAvailable(DeploymentModuleIdentifier deploymentModuleIdentifier, ModuleDeployment moduleDeployment)
DeploymentRepositoryListener
deploymentAvailable
in interface DeploymentRepositoryListener
deploymentModuleIdentifier
- The deploymentpublic void deploymentStarted(DeploymentModuleIdentifier deploymentModuleIdentifier, ModuleDeployment moduleDeployment)
DeploymentRepositoryListener
deploymentStarted
in interface DeploymentRepositoryListener
deploymentModuleIdentifier
- The deploymentpublic void deploymentRemoved(DeploymentModuleIdentifier deploymentModuleIdentifier)
DeploymentRepositoryListener
deploymentRemoved
in interface DeploymentRepositoryListener
deploymentModuleIdentifier
- The deploymentpublic void registryAdded(Registry<String,List<org.jboss.as.network.ClientMapping>> cluster)
registryAdded
in interface RegistryCollector.Listener<String,List<org.jboss.as.network.ClientMapping>>
public void registryRemoved(Registry<String,List<org.jboss.as.network.ClientMapping>> registry)
registryRemoved
in interface RegistryCollector.Listener<String,List<org.jboss.as.network.ClientMapping>>
public void preSuspend(org.jboss.as.server.suspend.ServerActivityCallback listener)
preSuspend
in interface org.jboss.as.server.suspend.ServerActivity
public void suspended(org.jboss.as.server.suspend.ServerActivityCallback listener)
suspended
in interface org.jboss.as.server.suspend.ServerActivity
public void resume()
resume
in interface org.jboss.as.server.suspend.ServerActivity
Copyright © 2018 JBoss by Red Hat. All rights reserved.