public class CoreProtocolManager extends Object implements ProtocolManager
Constructor and Description |
---|
CoreProtocolManager(HornetQServer server,
List<Interceptor> interceptors) |
Modifier and Type | Method and Description |
---|---|
void |
addSessionHandler(String name,
ServerSessionPacketHandler handler) |
ConnectionEntry |
createConnectionEntry(Acceptor acceptorUsed,
Connection connection) |
ServerSessionPacketHandler |
getSessionHandler(String sessionName) |
void |
handleBuffer(RemotingConnection connection,
HornetQBuffer buffer) |
int |
isReadyToHandle(HornetQBuffer buffer)
called by the remoting system prior to
BufferHandler.bufferReceived(Object, org.hornetq.api.core.HornetQBuffer) . |
void |
removeHandler(String name) |
public CoreProtocolManager(HornetQServer server, List<Interceptor> interceptors)
public ConnectionEntry createConnectionEntry(Acceptor acceptorUsed, Connection connection)
createConnectionEntry
in interface ProtocolManager
public ServerSessionPacketHandler getSessionHandler(String sessionName)
public void addSessionHandler(String name, ServerSessionPacketHandler handler)
public void removeHandler(String name)
removeHandler
in interface ProtocolManager
public void handleBuffer(RemotingConnection connection, HornetQBuffer buffer)
handleBuffer
in interface ProtocolManager
public int isReadyToHandle(HornetQBuffer buffer)
BufferDecoder
BufferHandler.bufferReceived(Object, org.hornetq.api.core.HornetQBuffer)
.
The implementation should return true if there is enough data in the buffer to decode. otherwise false.isReadyToHandle
in interface ProtocolManager
isReadyToHandle
in interface BufferDecoder
buffer
- the bufferCopyright © 2012 JBoss by Red Hat. All Rights Reserved.