public class ProtonClientSessionContext extends AbstractProtonSessionContext implements AMQPClientSessionContext
closed, connection, receivers, senders, session, sessionSPI
Constructor and Description |
---|
ProtonClientSessionContext(AMQPSessionCallback sessionSPI,
AbstractConnectionContext connection,
org.apache.qpid.proton.engine.Session session) |
Modifier and Type | Method and Description |
---|---|
AMQPClientSenderContext |
createDynamicSender(boolean preSettled) |
AMQPClientReceiverContext |
createReceiver(String address) |
AMQPClientReceiverContext |
createReceiver(String name,
String address) |
AMQPClientSenderContext |
createSender(String address,
boolean preSettled) |
close, disconnect, getTag, initialise, removeReceiver, removeSender, replaceTag
afterInit, isInitialized, waitWithTimeout
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
close, getTag, removeReceiver, removeSender, replaceTag
public ProtonClientSessionContext(AMQPSessionCallback sessionSPI, AbstractConnectionContext connection, org.apache.qpid.proton.engine.Session session)
public AMQPClientSenderContext createSender(String address, boolean preSettled) throws ActiveMQAMQPException
createSender
in interface AMQPClientSessionContext
ActiveMQAMQPException
public AMQPClientSenderContext createDynamicSender(boolean preSettled) throws ActiveMQAMQPException
createDynamicSender
in interface AMQPClientSessionContext
ActiveMQAMQPException
public AMQPClientReceiverContext createReceiver(String address) throws ActiveMQAMQPException
createReceiver
in interface AMQPClientSessionContext
ActiveMQAMQPException
public AMQPClientReceiverContext createReceiver(String name, String address) throws ActiveMQAMQPException
createReceiver
in interface AMQPClientSessionContext
ActiveMQAMQPException
Copyright © 2016 The Apache Software Foundation. All rights reserved.