org.hornetq.core.protocol.proton

Class ProtonSession

java.lang.Object

org.hornetq.core.protocol.proton.ProtonSession

All Implemented Interfaces:

SessionCallback

public class ProtonSession
extends Object
implements SessionCallback

Author:

Andy Taylor 4/10/13

Constructor Summary

Constructors

Constructor and Description
ProtonSession(String name, ProtonRemotingConnection connection, ProtonProtocolManager protonProtocolManager, OperationContext operationContext, HornetQServer server, org.apache.qpid.proton.engine.impl.TransportImpl protonTransport)

Method Summary

Methods

Modifier and Type	Method and Description
void	addConsumer(org.apache.qpid.proton.engine.Sender sender)
void	addProducer(org.apache.qpid.proton.engine.Receiver receiver)
void	addReadyListener(ReadyListener listener)
void	addTransactionHandler(org.apache.qpid.proton.amqp.transaction.Coordinator coordinator, org.apache.qpid.proton.engine.Receiver receiver)
void	close()
void	closed()
OperationContext	getContext()
ServerSession	getServerSession()
byte[]	getTag()
void	initialise(boolean transacted)
void	removeConsumer(long consumerID)
void	removeProducer(org.apache.qpid.proton.engine.Receiver receiver)
void	removeReadyListener(ReadyListener listener)
void	replaceTag(byte[] tag)
int	sendLargeMessage(ServerMessage message, long consumerID, long bodySize, int deliveryCount)
int	sendLargeMessageContinuation(long consumerID, byte[] body, boolean continues, boolean requiresResponse)
int	sendMessage(ServerMessage message, long consumerID, int deliveryCount)
void	sendProducerCreditsFailMessage(int credits, SimpleString address)
void	sendProducerCreditsMessage(int credits, SimpleString address)

Methods inherited from class java.lang.Object

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

Constructor Detail

ProtonSession

public ProtonSession(String name,
             ProtonRemotingConnection connection,
             ProtonProtocolManager protonProtocolManager,
             OperationContext operationContext,
             HornetQServer server,
             org.apache.qpid.proton.engine.impl.TransportImpl protonTransport)

Method Detail

getServerSession

public ServerSession getServerSession()

initialise

public void initialise(boolean transacted)
                throws HornetQAMQPInternalErrorException

Throws:

HornetQAMQPInternalErrorException

sendProducerCreditsMessage

public void sendProducerCreditsMessage(int credits,
                              SimpleString address)

Specified by:

sendProducerCreditsMessage in interface SessionCallback

sendProducerCreditsFailMessage

public void sendProducerCreditsFailMessage(int credits,
                                  SimpleString address)

Specified by:

sendProducerCreditsFailMessage in interface SessionCallback

sendMessage

public int sendMessage(ServerMessage message,
              long consumerID,
              int deliveryCount)

Specified by:

sendMessage in interface SessionCallback

sendLargeMessage

public int sendLargeMessage(ServerMessage message,
                   long consumerID,
                   long bodySize,
                   int deliveryCount)

Specified by:

sendLargeMessage in interface SessionCallback

sendLargeMessageContinuation

public int sendLargeMessageContinuation(long consumerID,
                               byte[] body,
                               boolean continues,
                               boolean requiresResponse)

Specified by:

sendLargeMessageContinuation in interface SessionCallback

closed

public void closed()

Specified by:

closed in interface SessionCallback

addReadyListener

public void addReadyListener(ReadyListener listener)

Specified by:

addReadyListener in interface SessionCallback

removeReadyListener

public void removeReadyListener(ReadyListener listener)

Specified by:

removeReadyListener in interface SessionCallback

getContext

public OperationContext getContext()

addProducer

public void addProducer(org.apache.qpid.proton.engine.Receiver receiver)
                 throws HornetQAMQPException

Throws:

HornetQAMQPException

addTransactionHandler

public void addTransactionHandler(org.apache.qpid.proton.amqp.transaction.Coordinator coordinator,
                         org.apache.qpid.proton.engine.Receiver receiver)

addConsumer

public void addConsumer(org.apache.qpid.proton.engine.Sender sender)
                 throws HornetQAMQPException

Throws:

HornetQAMQPException

getTag

public byte[] getTag()

replaceTag

public void replaceTag(byte[] tag)

close

public void close()

removeConsumer

public void removeConsumer(long consumerID)
                    throws HornetQAMQPException

Throws:

HornetQAMQPException

removeProducer

public void removeProducer(org.apache.qpid.proton.engine.Receiver receiver)