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

Class VersionOneProtocolChannelReceiver

java.lang.Object

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

All Implemented Interfaces:

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

Direct Known Subclasses:

VersionTwoProtocolChannelReceiver

public class VersionOneProtocolChannelReceiver
extends Object
implements org.jboss.remoting3.Channel.Receiver, DeploymentRepositoryListener, RegistryCollector.Listener<String,List<ClientMapping>>

Author:

Jaikiran Pai

Field Summary

Fields

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 Summary

Constructors

Constructor and Description

VersionOneProtocolChannelReceiver(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
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.
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()

Methods inherited from class java.lang.Object

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

Field Detail

channelAssociation

protected final ChannelAssociation channelAssociation

deploymentRepository

protected final DeploymentRepository deploymentRepository

transactionsRepository

protected final EJBRemoteTransactionsRepository transactionsRepository

marshallerFactory

protected final org.jboss.marshalling.MarshallerFactory marshallerFactory

executorService

protected final ExecutorService executorService

clientMappingRegistryCollector

protected final RegistryCollector<String,List<ClientMapping>> clientMappingRegistryCollector

clusterTopologyUpdateListeners

protected final Set<org.jboss.as.ejb3.remote.protocol.versionone.VersionOneProtocolChannelReceiver.ClusterTopologyUpdateListener> clusterTopologyUpdateListeners

remoteAsyncInvocationCancelStatus

protected final RemoteAsyncInvocationCancelStatusService remoteAsyncInvocationCancelStatus

Constructor Detail

VersionOneProtocolChannelReceiver

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

Method Detail

startReceiving

public void startReceiving()

handleError

public void handleError(org.jboss.remoting3.Channel channel,
                        IOException error)

Specified by:

handleError in interface org.jboss.remoting3.Channel.Receiver

handleEnd

public void handleEnd(org.jboss.remoting3.Channel channel)

Specified by:

handleEnd in interface org.jboss.remoting3.Channel.Receiver

handleMessage

public void handleMessage(org.jboss.remoting3.Channel channel,
                          org.jboss.remoting3.MessageInputStream messageInputStream)

Specified by:

handleMessage in interface org.jboss.remoting3.Channel.Receiver

getMessageHandler

protected MessageHandler getMessageHandler(byte header)

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

Parameters:

header - The message header

Returns:

processMessage

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

Throws:

IOException

listenerAdded

public void listenerAdded(DeploymentRepository repository)

Description copied from interface: DeploymentRepositoryListener

Called when the listener is added to the repository. This method runs in a synchronized block, so the listener can get the current state of the repository.

Specified by:

listenerAdded in interface DeploymentRepositoryListener

deploymentAvailable

public void deploymentAvailable(DeploymentModuleIdentifier deploymentModuleIdentifier,
                                ModuleDeployment moduleDeployment)

Description copied from interface: DeploymentRepositoryListener

Callback when a deployment becomes available

Specified by:

deploymentAvailable in interface DeploymentRepositoryListener

Parameters:

deploymentModuleIdentifier - The deployment

deploymentStarted

public void deploymentStarted(DeploymentModuleIdentifier deploymentModuleIdentifier,
                              ModuleDeployment moduleDeployment)

Description copied from interface: DeploymentRepositoryListener

Callback when a deployment has started, i.e. all components have started

Specified by:

deploymentStarted in interface DeploymentRepositoryListener

Parameters:

deploymentModuleIdentifier - The deployment

deploymentRemoved

public void deploymentRemoved(DeploymentModuleIdentifier deploymentModuleIdentifier)

Description copied from interface: DeploymentRepositoryListener

Called when a deployment is no longer available

Specified by:

deploymentRemoved in interface DeploymentRepositoryListener

Parameters:

deploymentModuleIdentifier - The deployment

registryAdded

public void registryAdded(Registry<String,List<ClientMapping>> cluster)

Specified by:

registryAdded in interface RegistryCollector.Listener<String,List<ClientMapping>>

registryRemoved

public void registryRemoved(Registry<String,List<ClientMapping>> registry)

Specified by:

registryRemoved in interface RegistryCollector.Listener<String,List<ClientMapping>>