public class VersionOneProtocolChannelReceiver extends Object implements org.jboss.remoting3.Channel.Receiver, DeploymentRepositoryListener, RegistryCollector.Listener<String,List<ClientMapping>>
Modifier and Type | Field and Description |
---|---|
protected ChannelAssociation |
channelAssociation |
protected RegistryCollector<String,List<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 EJBRemoteTransactionsRepository |
transactionsRepository |
Constructor and Description |
---|
VersionOneProtocolChannelReceiver(ChannelAssociation channelAssociation,
DeploymentRepository deploymentRepository,
EJBRemoteTransactionsRepository transactionsRepository,
RegistryCollector<String,List<ClientMapping>> clientMappingRegistryCollector,
org.jboss.marshalling.MarshallerFactory marshallerFactory,
ExecutorService executorService,
RemoteAsyncInvocationCancelStatusService asyncInvocationCancelStatusService) |
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
|
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.
|
protected void |
processMessage(org.jboss.remoting3.Channel channel,
InputStream inputStream) |
void |
registryAdded(Registry<String,List<ClientMapping>> cluster) |
void |
registryRemoved(Registry<String,List<ClientMapping>> registry) |
void |
startReceiving() |
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<ClientMapping>> clientMappingRegistryCollector
protected final Set<org.jboss.as.ejb3.remote.protocol.versionone.VersionOneProtocolChannelReceiver.ClusterTopologyUpdateListener> clusterTopologyUpdateListeners
protected final RemoteAsyncInvocationCancelStatusService remoteAsyncInvocationCancelStatus
public VersionOneProtocolChannelReceiver(ChannelAssociation channelAssociation, DeploymentRepository deploymentRepository, EJBRemoteTransactionsRepository transactionsRepository, RegistryCollector<String,List<ClientMapping>> clientMappingRegistryCollector, org.jboss.marshalling.MarshallerFactory marshallerFactory, ExecutorService executorService, RemoteAsyncInvocationCancelStatusService asyncInvocationCancelStatusService)
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 deploymentRemoved(DeploymentModuleIdentifier deploymentModuleIdentifier)
DeploymentRepositoryListener
deploymentRemoved
in interface DeploymentRepositoryListener
deploymentModuleIdentifier
- The deploymentpublic void registryAdded(Registry<String,List<ClientMapping>> cluster)
registryAdded
in interface RegistryCollector.Listener<String,List<ClientMapping>>
public void registryRemoved(Registry<String,List<ClientMapping>> registry)
registryRemoved
in interface RegistryCollector.Listener<String,List<ClientMapping>>
Copyright © 2013 JBoss by Red Hat. All rights reserved.