public class AmqpConnectionSession extends AmqpSession
closeRequest, closeTimeoutTask
Constructor and Description |
---|
AmqpConnectionSession(AmqpConnection connection,
JmsSessionInfo info,
org.apache.qpid.proton.engine.Session session)
Create a new instance of a Connection owned Session object.
|
Modifier and Type | Method and Description |
---|---|
void |
unsubscribe(String subscriptionName,
AsyncResult request)
Used to remove an existing durable topic subscription from the remote broker.
|
acknowledge, addChildResource, begin, commit, containsSubscription, createConsumer, createProducer, getConnection, getConsumer, getConsumer, getProducer, getProducer, getProvider, getSessionId, getTransactionContext, isTransactionFailed, recover, removeChildResource, reportError, rollback, schedule, toString
close, closeOrDetachEndpoint, getEndpoint, getLocalState, getParent, getRemoteState, getResourceInfo, isAwaitingClose, isClosed, isOpen, processDeliveryUpdates, processFlowUpdates, processRemoteClose, processRemoteDetach, processRemoteOpen, remotelyClosed, resourceClosed
public AmqpConnectionSession(AmqpConnection connection, JmsSessionInfo info, org.apache.qpid.proton.engine.Session session)
connection
- the connection that owns this session.info
- the JmsSessionInfo
for the Session to create.session
- the Proton session instance that this resource wraps.public void unsubscribe(String subscriptionName, AsyncResult request)
subscriptionName
- the subscription name that is to be removed.request
- the request that awaits the completion of this action.Copyright © 2013–2016 The Apache Software Foundation. All rights reserved.