org.apache.activemq.artemis.core.protocol.core

Class ServerSessionPacketHandler

java.lang.Object

org.apache.activemq.artemis.core.protocol.core.ServerSessionPacketHandler

All Implemented Interfaces:

ChannelHandler

public class ServerSessionPacketHandler
extends Object
implements ChannelHandler

Constructor Summary

Constructors

Constructor and Description
ServerSessionPacketHandler(Executor callExecutor, ServerSession session, StorageManager storageManager, Channel channel)

Method Summary

Modifier and Type	Method and Description
void	close()
void	closeListeners()
void	connectionFailed(ActiveMQException exception, boolean failedOver)
void	flushExecutor()
Channel	getChannel()
long	getID()
ServerSession	getSession()
void	handlePacket(Packet packet) called by the channel when a packet is received..
int	transferConnection(CoreRemotingConnection newConnection, int lastReceivedCommandID)

Methods inherited from class java.lang.Object

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

Constructor Detail

ServerSessionPacketHandler

public ServerSessionPacketHandler(Executor callExecutor,
                                  ServerSession session,
                                  StorageManager storageManager,
                                  Channel channel)

Method Detail

getSession

public ServerSession getSession()

getID

public long getID()

connectionFailed

public void connectionFailed(ActiveMQException exception,
                             boolean failedOver)

flushExecutor

public void flushExecutor()

close

public void close()

getChannel

public Channel getChannel()

handlePacket

public void handlePacket(Packet packet)

Description copied from interface: ChannelHandler

called by the channel when a packet is received..

Specified by:

handlePacket in interface ChannelHandler

Parameters:

packet - the packet received

closeListeners

public void closeListeners()

transferConnection

public int transferConnection(CoreRemotingConnection newConnection,
                              int lastReceivedCommandID)