public class ServerSessionPacketHandler extends Object implements ChannelHandler
Constructor and Description |
---|
ServerSessionPacketHandler(Executor callExecutor,
ServerSession session,
StorageManager storageManager,
Channel channel) |
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) |
int |
transferConnection(CoreRemotingConnection newConnection,
int lastReceivedCommandID) |
public ServerSessionPacketHandler(Executor callExecutor, ServerSession session, StorageManager storageManager, Channel channel)
public ServerSession getSession()
public long getID()
public void connectionFailed(ActiveMQException exception, boolean failedOver)
public void flushExecutor()
public void close()
public Channel getChannel()
public void handlePacket(Packet packet)
handlePacket
in interface ChannelHandler
public void closeListeners()
public int transferConnection(CoreRemotingConnection newConnection, int lastReceivedCommandID)
Copyright © 2018 The Apache Software Foundation. All Rights Reserved.