public class VersionTwoProtocolChannelReceiver extends VersionOneProtocolChannelReceiver
channelAssociation, clientMappingRegistryCollector, clusterTopologyUpdateListeners, deploymentRepository, executorService, marshallerFactory, remoteAsyncInvocationCancelStatus, transactionsRepository
Constructor and Description |
---|
VersionTwoProtocolChannelReceiver(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 |
---|---|
protected MessageHandler |
getMessageHandler(byte header)
Returns a
MessageHandler which can handle a message represented by the passed header . |
protected void |
processMessage(org.jboss.remoting3.Channel channel,
InputStream inputStream) |
deploymentAvailable, deploymentRemoved, deploymentStarted, handleEnd, handleError, handleMessage, listenerAdded, registryAdded, registryRemoved, startReceiving
public VersionTwoProtocolChannelReceiver(ChannelAssociation channelAssociation, DeploymentRepository deploymentRepository, EJBRemoteTransactionsRepository transactionsRepository, RegistryCollector<String,List<ClientMapping>> clientMappingRegistryCollector, org.jboss.marshalling.MarshallerFactory marshallerFactory, ExecutorService executorService, RemoteAsyncInvocationCancelStatusService asyncInvocationCancelStatusService)
protected MessageHandler getMessageHandler(byte header)
VersionOneProtocolChannelReceiver
MessageHandler
which can handle a message represented by the passed header
. Returns null if there's no such MessageHandler
getMessageHandler
in class VersionOneProtocolChannelReceiver
header
- The message headerprotected void processMessage(org.jboss.remoting3.Channel channel, InputStream inputStream) throws IOException
processMessage
in class VersionOneProtocolChannelReceiver
IOException
Copyright © 2015 JBoss by Red Hat. All rights reserved.