org.hornetq.core.protocol.proton

Class ProtonProtocolManager

java.lang.Object

org.hornetq.core.protocol.proton.ProtonProtocolManager

All Implemented Interfaces:

NotificationListener, ProtocolManager

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

Modifier and Type	Method and Description
void	addChannelHandlers(io.netty.channel.ChannelPipeline pipeliner)
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)
void	handshake(NettyServerConnection connection, HornetQBuffer buffer)
boolean	isProtocol(byte[] array)
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

handleBuffer

public void handleBuffer(RemotingConnection connection,
                         HornetQBuffer buffer)

Specified by:

handleBuffer in interface ProtocolManager

addChannelHandlers

public void addChannelHandlers(io.netty.channel.ChannelPipeline pipeliner)

Specified by:

addChannelHandlers in interface ProtocolManager

isProtocol

public boolean isProtocol(byte[] array)

Specified by:

isProtocol in interface ProtocolManager

handshake

public void handshake(NettyServerConnection connection,
                      HornetQBuffer buffer)

Specified by:

handshake 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)