org.jboss.as.ejb3.remote.protocol.versiontwo

Class VersionTwoProtocolChannelReceiver

java.lang.Object

org.jboss.as.ejb3.remote.protocol.versionone.VersionOneProtocolChannelReceiver

org.jboss.as.ejb3.remote.protocol.versiontwo.VersionTwoProtocolChannelReceiver

All Implemented Interfaces:

DeploymentRepositoryListener, RegistryCollector.Listener<String,List<ClientMapping>>, org.jboss.remoting3.Channel.Receiver

public class VersionTwoProtocolChannelReceiver
extends VersionOneProtocolChannelReceiver

Author:

Jaikiran Pai

Field Summary

Fields inherited from class org.jboss.as.ejb3.remote.protocol.versionone.VersionOneProtocolChannelReceiver

channelAssociation, clientMappingRegistryCollector, clusterTopologyUpdateListeners, deploymentRepository, executorService, marshallerFactory, remoteAsyncInvocationCancelStatus, transactionsRepository

Constructor Summary

Constructors

Constructor and Description

VersionTwoProtocolChannelReceiver(ChannelAssociation channelAssociation, DeploymentRepository deploymentRepository, EJBRemoteTransactionsRepository transactionsRepository, RegistryCollector<String,List<ClientMapping>> clientMappingRegistryCollector, org.jboss.marshalling.MarshallerFactory marshallerFactory, ExecutorService executorService, RemoteAsyncInvocationCancelStatusService asyncInvocationCancelStatusService)

Method Summary

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)

Methods inherited from class org.jboss.as.ejb3.remote.protocol.versionone.VersionOneProtocolChannelReceiver

deploymentAvailable, deploymentRemoved, deploymentStarted, handleEnd, handleError, handleMessage, listenerAdded, registryAdded, registryRemoved, startReceiving

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

VersionTwoProtocolChannelReceiver

public VersionTwoProtocolChannelReceiver(ChannelAssociation channelAssociation,
                                         DeploymentRepository deploymentRepository,
                                         EJBRemoteTransactionsRepository transactionsRepository,
                                         RegistryCollector<String,List<ClientMapping>> clientMappingRegistryCollector,
                                         org.jboss.marshalling.MarshallerFactory marshallerFactory,
                                         ExecutorService executorService,
                                         RemoteAsyncInvocationCancelStatusService asyncInvocationCancelStatusService)

Method Detail

getMessageHandler

protected MessageHandler getMessageHandler(byte header)

Description copied from class: VersionOneProtocolChannelReceiver

Returns a MessageHandler which can handle a message represented by the passed header. Returns null if there's no such MessageHandler

Overrides:

getMessageHandler in class VersionOneProtocolChannelReceiver

Parameters:

header - The message header

Returns:

processMessage

protected void processMessage(org.jboss.remoting3.Channel channel,
                              InputStream inputStream)
                       throws IOException

Overrides:

processMessage in class VersionOneProtocolChannelReceiver

Throws:

IOException