org.hornetq.core.protocol.proton

Class ProtonProtocolManager

java.lang.Object

org.hornetq.core.protocol.proton.ProtonProtocolManager

All Implemented Interfaces:

NotificationListener, ProtocolManager, BufferDecoder

public class ProtonProtocolManager
extends Object
implements ProtocolManager, NotificationListener

A proton protocol manager, basically reads the Proton Input and maps proton resources to HornetQ resources

Author:

Andy Taylor

Field Summary

Fields

Modifier and Type	Field and Description
static EnumSet<org.apache.qpid.proton.engine.EndpointState>	ACTIVE
static EnumSet<org.apache.qpid.proton.engine.EndpointState>	ANY_ENDPOINT_STATE
static EnumSet<org.apache.qpid.proton.engine.EndpointState>	CLOSED
static EnumSet<org.apache.qpid.proton.engine.EndpointState>	INITIALIZED
static EnumSet<org.apache.qpid.proton.engine.EndpointState>	UNINITIALIZED

Constructor Summary

Constructors

Constructor and Description
ProtonProtocolManager(HornetQServer server)

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)
ServerMessageImpl	createServerMessage()
ProtonSession	createSession(ProtonRemotingConnection protonConnection, org.apache.qpid.proton.engine.impl.TransportImpl protonTransport)
void	handleBuffer(RemotingConnection connection, HornetQBuffer buffer)
void	handleDelivery(org.apache.qpid.proton.engine.Sender sender, byte[] tag, org.apache.qpid.proton.jms.EncodedMessage encodedMessage, ServerMessage message, ProtonRemotingConnection connection, boolean preSettle)
void	handleMessage(org.apache.qpid.proton.engine.Receiver receiver, HornetQBuffer buffer, org.apache.qpid.proton.engine.Delivery delivery, ProtonRemotingConnection connection, ProtonSession protonSession, String address)
void	handleTransaction(org.apache.qpid.proton.engine.Receiver receiver, HornetQBuffer buffer, org.apache.qpid.proton.engine.Delivery delivery, ProtonSession protonSession)
int	isReadyToHandle(HornetQBuffer buffer) called by the remoting system prior to BufferHandler.bufferReceived(Object, org.hornetq.api.core.HornetQBuffer).
boolean	isSupportsWebsockets(String protocol)
byte[]	longToBytes(long x)
void	onNotification(Notification notification)
void	removeHandler(String name)

Methods inherited from class java.lang.Object

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

Field Detail

UNINITIALIZED

public static final EnumSet<org.apache.qpid.proton.engine.EndpointState> UNINITIALIZED

INITIALIZED

public static final EnumSet<org.apache.qpid.proton.engine.EndpointState> INITIALIZED

ACTIVE

public static final EnumSet<org.apache.qpid.proton.engine.EndpointState> ACTIVE

CLOSED

public static final EnumSet<org.apache.qpid.proton.engine.EndpointState> CLOSED

ANY_ENDPOINT_STATE

public static final EnumSet<org.apache.qpid.proton.engine.EndpointState> ANY_ENDPOINT_STATE

Constructor Detail

ProtonProtocolManager

public ProtonProtocolManager(HornetQServer server)

Method Detail

createConnectionEntry

public ConnectionEntry createConnectionEntry(Acceptor acceptorUsed,
                                    Connection connection)

Specified by:

createConnectionEntry in interface ProtocolManager

removeHandler

public void removeHandler(String name)

Specified by:

removeHandler 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..

handleBuffer

public void handleBuffer(RemotingConnection connection,
                HornetQBuffer buffer)

Specified by:

handleBuffer in interface ProtocolManager

addChannelHandlers

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

Specified by:

addChannelHandlers in interface ProtocolManager

isSupportsWebsockets

public boolean isSupportsWebsockets(String protocol)

Specified by:

isSupportsWebsockets in interface ProtocolManager

onNotification

public void onNotification(Notification notification)

Specified by:

onNotification in interface NotificationListener

createServerMessage

public ServerMessageImpl createServerMessage()

handleMessage

public void handleMessage(org.apache.qpid.proton.engine.Receiver receiver,
                 HornetQBuffer buffer,
                 org.apache.qpid.proton.engine.Delivery delivery,
                 ProtonRemotingConnection connection,
                 ProtonSession protonSession,
                 String address)
                   throws Exception

Throws:

Exception

handleDelivery

public void handleDelivery(org.apache.qpid.proton.engine.Sender sender,
                  byte[] tag,
                  org.apache.qpid.proton.jms.EncodedMessage encodedMessage,
                  ServerMessage message,
                  ProtonRemotingConnection connection,
                  boolean preSettle)

createSession

public ProtonSession createSession(ProtonRemotingConnection protonConnection,
                          org.apache.qpid.proton.engine.impl.TransportImpl protonTransport)
                            throws HornetQAMQPException

Throws:

HornetQAMQPException

handleTransaction

public void handleTransaction(org.apache.qpid.proton.engine.Receiver receiver,
                     HornetQBuffer buffer,
                     org.apache.qpid.proton.engine.Delivery delivery,
                     ProtonSession protonSession)
                       throws HornetQAMQPIllegalStateException

Throws:

HornetQAMQPIllegalStateException

longToBytes

public byte[] longToBytes(long x)