public class VersionTwoProtocolChannelReceiver extends VersionOneProtocolChannelReceiver
channelAssociation, clientMappingRegistryCollector, clusterTopologyUpdateListeners, deploymentRepository, executorService, marshallerFactory, remoteAsyncInvocationCancelStatus, suspendController, transactionsRepository
Constructor and Description |
---|
VersionTwoProtocolChannelReceiver(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 |
---|---|
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, preSuspend, registryAdded, registryRemoved, resume, startReceiving, suspended
public VersionTwoProtocolChannelReceiver(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)
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 © 2018 JBoss by Red Hat. All rights reserved.