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

Class ServerSessionPacketHandler

java.lang.Object

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

All Implemented Interfaces:

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

public class ServerSessionPacketHandler
extends Object
implements org.apache.activemq.artemis.core.protocol.core.ChannelHandler

Constructor Summary

Constructors

Constructor and Description
ServerSessionPacketHandler(ServerSession session, StorageManager storageManager, org.apache.activemq.artemis.core.protocol.core.Channel channel)

Method Summary

Modifier and Type	Method and Description
void	close()
void	closeListeners()
void	connectionFailed(org.apache.activemq.artemis.api.core.ActiveMQException exception, boolean failedOver)
org.apache.activemq.artemis.core.protocol.core.Channel	getChannel()
long	getID()
ServerSession	getSession()
void	handlePacket(org.apache.activemq.artemis.core.protocol.core.Packet packet)
int	transferConnection(org.apache.activemq.artemis.core.protocol.core.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(ServerSession session,
                                  StorageManager storageManager,
                                  org.apache.activemq.artemis.core.protocol.core.Channel channel)

Method Detail

getSession

public ServerSession getSession()

getID

public long getID()

connectionFailed

public void connectionFailed(org.apache.activemq.artemis.api.core.ActiveMQException exception,
                             boolean failedOver)

close

public void close()

getChannel

public org.apache.activemq.artemis.core.protocol.core.Channel getChannel()

handlePacket

public void handlePacket(org.apache.activemq.artemis.core.protocol.core.Packet packet)

Specified by:

handlePacket in interface org.apache.activemq.artemis.core.protocol.core.ChannelHandler

closeListeners

public void closeListeners()

transferConnection

public int transferConnection(org.apache.activemq.artemis.core.protocol.core.CoreRemotingConnection newConnection,
                              int lastReceivedCommandID)