public class ProtonServerSessionContext extends AbstractProtonSessionContext
Modifier and Type | Field and Description |
---|---|
protected Map<Object,AbstractProtonContextSender> |
serverSenders |
closed, connection, receivers, senders, session, sessionSPI
Constructor and Description |
---|
ProtonServerSessionContext(AMQPSessionCallback sessionSPI,
AbstractConnectionContext connection,
org.apache.qpid.proton.engine.Session session) |
Modifier and Type | Method and Description |
---|---|
void |
addReceiver(org.apache.qpid.proton.engine.Receiver receiver) |
void |
addSender(org.apache.qpid.proton.engine.Sender sender) |
void |
addTransactionHandler(org.apache.qpid.proton.amqp.transaction.Coordinator coordinator,
org.apache.qpid.proton.engine.Receiver receiver) |
void |
removeSender(org.apache.qpid.proton.engine.Sender sender) |
int |
serverDelivery(Object message,
Object consumer,
int deliveryCount)
The consumer object from the broker or the key used to store the sender
|
close, disconnect, getTag, initialise, removeReceiver, replaceTag
afterInit, isInitialized, waitWithTimeout
protected Map<Object,AbstractProtonContextSender> serverSenders
public ProtonServerSessionContext(AMQPSessionCallback sessionSPI, AbstractConnectionContext connection, org.apache.qpid.proton.engine.Session session)
public int serverDelivery(Object message, Object consumer, int deliveryCount) throws Exception
message
- consumer
- deliveryCount
- Exception
public void addTransactionHandler(org.apache.qpid.proton.amqp.transaction.Coordinator coordinator, org.apache.qpid.proton.engine.Receiver receiver)
public void addSender(org.apache.qpid.proton.engine.Sender sender) throws Exception
Exception
public void removeSender(org.apache.qpid.proton.engine.Sender sender) throws ActiveMQAMQPException
removeSender
in interface AMQPSessionContext
removeSender
in class AbstractProtonSessionContext
ActiveMQAMQPException
Copyright © 2016 The Apache Software Foundation. All rights reserved.