public class ProtonSession extends Object implements SessionCallback
Constructor and Description |
---|
ProtonSession(String name,
ProtonRemotingConnection connection,
ProtonProtocolManager protonProtocolManager,
OperationContext operationContext,
HornetQServer server,
org.apache.qpid.proton.engine.impl.TransportImpl protonTransport) |
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() |
void |
disconnect(long consumerId,
String queueName) |
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) |
public ProtonSession(String name, ProtonRemotingConnection connection, ProtonProtocolManager protonProtocolManager, OperationContext operationContext, HornetQServer server, org.apache.qpid.proton.engine.impl.TransportImpl protonTransport)
public ServerSession getServerSession()
public void initialise(boolean transacted) throws HornetQAMQPInternalErrorException
public void sendProducerCreditsMessage(int credits, SimpleString address)
sendProducerCreditsMessage
in interface SessionCallback
public void sendProducerCreditsFailMessage(int credits, SimpleString address)
sendProducerCreditsFailMessage
in interface SessionCallback
public int sendMessage(ServerMessage message, long consumerID, int deliveryCount)
sendMessage
in interface SessionCallback
public int sendLargeMessage(ServerMessage message, long consumerID, long bodySize, int deliveryCount)
sendLargeMessage
in interface SessionCallback
public int sendLargeMessageContinuation(long consumerID, byte[] body, boolean continues, boolean requiresResponse)
sendLargeMessageContinuation
in interface SessionCallback
public void closed()
closed
in interface SessionCallback
public void addReadyListener(ReadyListener listener)
addReadyListener
in interface SessionCallback
public void removeReadyListener(ReadyListener listener)
removeReadyListener
in interface SessionCallback
public void disconnect(long consumerId, String queueName)
disconnect
in interface SessionCallback
public OperationContext getContext()
public void addProducer(org.apache.qpid.proton.engine.Receiver receiver) throws HornetQAMQPException
HornetQAMQPException
public void addTransactionHandler(org.apache.qpid.proton.amqp.transaction.Coordinator coordinator, org.apache.qpid.proton.engine.Receiver receiver)
public void addConsumer(org.apache.qpid.proton.engine.Sender sender) throws HornetQAMQPException
HornetQAMQPException
public byte[] getTag()
public void replaceTag(byte[] tag)
public void close()
public void removeConsumer(long consumerID) throws HornetQAMQPException
HornetQAMQPException
public void removeProducer(org.apache.qpid.proton.engine.Receiver receiver)
Copyright © 2015 JBoss, a division of Red Hat. All rights reserved.