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

Class VersionOneProtocolChannelReceiver

java.lang.Object

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

All Implemented Interfaces:

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

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

Author:

Jaikiran Pai

Constructor Summary

Constructors

Constructor and Description
VersionOneProtocolChannelReceiver(org.jboss.remoting3.Channel channel, DeploymentRepository deploymentRepository, EJBRemoteTransactionsRepository transactionsRepository, RegistryCollector<String,List<ClientMapping>> clientMappingRegistryCollector, org.jboss.marshalling.MarshallerFactory marshallerFactory, ExecutorService executorService)

Method Summary

Methods

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	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.
void	registryAdded(Registry<String,List<ClientMapping>> registry)
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

Constructor Detail

VersionOneProtocolChannelReceiver

public VersionOneProtocolChannelReceiver(org.jboss.remoting3.Channel channel,
                                 DeploymentRepository deploymentRepository,
                                 EJBRemoteTransactionsRepository transactionsRepository,
                                 RegistryCollector<String,List<ClientMapping>> clientMappingRegistryCollector,
                                 org.jboss.marshalling.MarshallerFactory marshallerFactory,
                                 ExecutorService executorService)

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

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

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>> registry)

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>>