Package | Description |
---|---|
org.apache.qpid.jms |
The core AMQP JMS client implementation classes.
|
org.apache.qpid.jms.meta | |
org.apache.qpid.jms.provider | |
org.apache.qpid.jms.provider.amqp | |
org.apache.qpid.jms.provider.failover |
Modifier and Type | Method and Description |
---|---|
protected JmsSessionId |
JmsConnection.getNextSessionId() |
protected JmsSessionId |
JmsSession.getSessionId() |
Constructor and Description |
---|
JmsQueueSession(JmsConnection connection,
JmsSessionId sessionId,
int acknowledgementMode) |
JmsSession(JmsConnection connection,
JmsSessionId sessionId,
int acknowledgementMode) |
JmsTopicSession(JmsConnection connection,
JmsSessionId sessionId,
int acknowledgementMode) |
Modifier and Type | Method and Description |
---|---|
JmsSessionId |
JmsSessionInfo.getId() |
JmsSessionId |
JmsConsumerId.getParentId() |
JmsSessionId |
JmsProducerInfo.getParentId() |
JmsSessionId |
JmsProducerId.getParentId() |
JmsSessionId |
JmsConsumerInfo.getParentId() |
JmsSessionId |
JmsTransactionInfo.getSessionId() |
Modifier and Type | Method and Description |
---|---|
int |
JmsSessionId.compareTo(JmsSessionId other) |
Constructor and Description |
---|
JmsConnectionId(JmsSessionId id) |
JmsConsumerId(JmsSessionId sessionId,
long consumerId) |
JmsProducerId(JmsSessionId sessionId,
long producerId) |
JmsSessionId(JmsSessionId id) |
JmsSessionInfo(JmsSessionId sessionId) |
JmsTransactionInfo(JmsSessionId sessionId,
JmsTransactionId transactionId) |
Modifier and Type | Method and Description |
---|---|
void |
Provider.acknowledge(JmsSessionId sessionId,
ProviderConstants.ACK_TYPE ackType,
AsyncResult request)
Called to acknowledge all messages that have been delivered in a given session.
|
void |
ProviderWrapper.acknowledge(JmsSessionId sessionId,
ProviderConstants.ACK_TYPE ackType,
AsyncResult request) |
void |
Provider.recover(JmsSessionId sessionId,
AsyncResult request)
Called to recover all unacknowledged messages for a Session in client Ack mode.
|
void |
ProviderWrapper.recover(JmsSessionId sessionId,
AsyncResult request) |
Modifier and Type | Method and Description |
---|---|
JmsSessionId |
AmqpSession.getSessionId() |
Modifier and Type | Method and Description |
---|---|
void |
AmqpProvider.acknowledge(JmsSessionId sessionId,
ProviderConstants.ACK_TYPE ackType,
AsyncResult request) |
AmqpSession |
AmqpConnection.getSession(JmsSessionId sessionId)
Retrieve the indicated Session instance from the list of active sessions.
|
void |
AmqpProvider.recover(JmsSessionId sessionId,
AsyncResult request) |
Modifier and Type | Method and Description |
---|---|
void |
FailoverProvider.acknowledge(JmsSessionId sessionId,
ProviderConstants.ACK_TYPE ackType,
AsyncResult request) |
void |
FailoverProvider.recover(JmsSessionId sessionId,
AsyncResult request) |
Copyright © 2013–2016 The Apache Software Foundation. All rights reserved.