org.hornetq.core.protocol.core.impl

Class CoreProtocolManager

java.lang.Object

org.hornetq.core.protocol.core.impl.CoreProtocolManager

All Implemented Interfaces:

ProtocolManager, BufferDecoder

public class CoreProtocolManager
extends Object
implements ProtocolManager

A CoreProtocolManager

Author:

Tim Fox

Constructor Summary

Constructors

Constructor and Description
CoreProtocolManager(HornetQServer server, List<Interceptor> interceptors)

Method Summary

Methods

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)

Methods inherited from class java.lang.Object

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

Constructor Detail

CoreProtocolManager

public CoreProtocolManager(HornetQServer server,
                   List<Interceptor> interceptors)

Method Detail

createConnectionEntry

public ConnectionEntry createConnectionEntry(Acceptor acceptorUsed,
                                    Connection connection)

Specified by:

createConnectionEntry in interface ProtocolManager

getSessionHandler

public ServerSessionPacketHandler getSessionHandler(String sessionName)

addSessionHandler

public void addSessionHandler(String name,
                     ServerSessionPacketHandler handler)

removeHandler

public void removeHandler(String name)

Specified by:

removeHandler in interface ProtocolManager

handleBuffer

public void handleBuffer(RemotingConnection connection,
                HornetQBuffer buffer)

Specified by:

handleBuffer in interface ProtocolManager

isReadyToHandle

public int isReadyToHandle(HornetQBuffer buffer)

Description copied from interface: BufferDecoder

called by the remoting system prior to 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.

Specified by:

isReadyToHandle in interface ProtocolManager

Specified by:

isReadyToHandle in interface BufferDecoder

Parameters:

buffer - the buffer

Returns:

true id the buffer can be decoded..