org.hornetq.spi.core.protocol

Interface ProtocolManager

All Superinterfaces:

BufferDecoder

All Known Implementing Classes:

ProtonProtocolManager

public interface ProtocolManager
extends BufferDecoder

A ProtocolManager

Author:

Tim Fox

Method Summary

Methods

Modifier and Type	Method and Description
void	addChannelHandlers(String protocol, Map<String,org.jboss.netty.channel.ChannelHandler> handlers, BufferDecoder decoder)
ConnectionEntry	createConnectionEntry(Acceptor acceptorUsed, Connection connection)
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).
boolean	isSupportsWebsockets(String protocol)
void	removeHandler(String name)

Method Detail

createConnectionEntry

ConnectionEntry createConnectionEntry(Acceptor acceptorUsed,
                                    Connection connection)

removeHandler

void removeHandler(String name)

isReadyToHandle

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 BufferDecoder

Parameters:

buffer - the buffer

Returns:

true id the buffer can be decoded..

handleBuffer

void handleBuffer(RemotingConnection connection,
                HornetQBuffer buffer)

addChannelHandlers

void addChannelHandlers(String protocol,
                      Map<String,org.jboss.netty.channel.ChannelHandler> handlers,
                      BufferDecoder decoder)

isSupportsWebsockets

boolean isSupportsWebsockets(String protocol)