public abstract class AbstractProtonSessionContext extends ProtonInitializable implements AMQPSessionContext
Modifier and Type | Field and Description |
---|---|
protected boolean |
closed |
protected AbstractConnectionContext |
connection |
protected Map<org.apache.qpid.proton.engine.Receiver,AbstractProtonReceiverContext> |
receivers |
protected Map<org.apache.qpid.proton.engine.Sender,AbstractProtonContextSender> |
senders |
protected org.apache.qpid.proton.engine.Session |
session |
protected AMQPSessionCallback |
sessionSPI |
Constructor and Description |
---|
AbstractProtonSessionContext(AMQPSessionCallback sessionSPI,
AbstractConnectionContext connection,
org.apache.qpid.proton.engine.Session session) |
Modifier and Type | Method and Description |
---|---|
void |
close() |
void |
disconnect(Object consumer,
String queueName)
TODO: maybe it needs to go?
|
byte[] |
getTag() |
void |
initialise() |
void |
removeReceiver(org.apache.qpid.proton.engine.Receiver receiver) |
void |
removeSender(org.apache.qpid.proton.engine.Sender sender) |
void |
replaceTag(byte[] tag) |
afterInit, isInitialized, waitWithTimeout
protected final AbstractConnectionContext connection
protected final AMQPSessionCallback sessionSPI
protected final org.apache.qpid.proton.engine.Session session
protected Map<org.apache.qpid.proton.engine.Receiver,AbstractProtonReceiverContext> receivers
protected Map<org.apache.qpid.proton.engine.Sender,AbstractProtonContextSender> senders
protected boolean closed
public AbstractProtonSessionContext(AMQPSessionCallback sessionSPI, AbstractConnectionContext connection, org.apache.qpid.proton.engine.Session session)
public void initialise() throws Exception
initialise
in class ProtonInitializable
Exception
public void disconnect(Object consumer, String queueName)
consumer
- queueName
- public byte[] getTag()
getTag
in interface AMQPSessionContext
public void replaceTag(byte[] tag)
replaceTag
in interface AMQPSessionContext
public void close()
close
in interface AMQPSessionContext
public void removeSender(org.apache.qpid.proton.engine.Sender sender) throws ActiveMQAMQPException
removeSender
in interface AMQPSessionContext
ActiveMQAMQPException
public void removeReceiver(org.apache.qpid.proton.engine.Receiver receiver)
removeReceiver
in interface AMQPSessionContext
Copyright © 2016 The Apache Software Foundation. All rights reserved.