Package | Description |
---|---|
org.apache.qpid.jms |
The core AMQP JMS client implementation classes.
|
org.apache.qpid.jms.provider | |
org.apache.qpid.jms.provider.amqp | |
org.apache.qpid.jms.provider.failover |
Modifier and Type | Method and Description |
---|---|
void |
JmsTransactionContext.acknowledge(JmsConnection connection,
JmsInboundMessageDispatch envelope,
ProviderConstants.ACK_TYPE ackType)
Allows the context to intercept a message acknowledgement and perform any
additional logic prior to the acknowledge being forwarded onto the connection.
|
void |
JmsNoTxTransactionContext.acknowledge(JmsConnection connection,
JmsInboundMessageDispatch envelope,
ProviderConstants.ACK_TYPE ackType) |
void |
JmsLocalTransactionContext.acknowledge(JmsConnection connection,
JmsInboundMessageDispatch envelope,
ProviderConstants.ACK_TYPE ackType) |
Modifier and Type | Method and Description |
---|---|
static ProviderConstants.ACK_TYPE |
ProviderConstants.ACK_TYPE.valueOf(String name)
Returns the enum constant of this type with the specified name.
|
static ProviderConstants.ACK_TYPE[] |
ProviderConstants.ACK_TYPE.values()
Returns an array containing the constants of this enum type, in
the order they are declared.
|
Modifier and Type | Method and Description |
---|---|
void |
Provider.acknowledge(JmsInboundMessageDispatch envelope,
ProviderConstants.ACK_TYPE ackType,
AsyncResult request)
Called to acknowledge a JmsMessage has been delivered, consumed, re-delivered...etc.
|
void |
ProviderWrapper.acknowledge(JmsInboundMessageDispatch envelope,
ProviderConstants.ACK_TYPE ackType,
AsyncResult request) |
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) |
Modifier and Type | Method and Description |
---|---|
void |
AmqpConsumer.acknowledge(JmsInboundMessageDispatch envelope,
ProviderConstants.ACK_TYPE ackType)
Called to acknowledge a given delivery.
|
void |
AmqpProvider.acknowledge(JmsInboundMessageDispatch envelope,
ProviderConstants.ACK_TYPE ackType,
AsyncResult request) |
void |
AmqpProvider.acknowledge(JmsSessionId sessionId,
ProviderConstants.ACK_TYPE ackType,
AsyncResult request) |
void |
AmqpSession.acknowledge(ProviderConstants.ACK_TYPE ackType)
Perform an acknowledge of all delivered messages for all consumers active in this
Session.
|
void |
AmqpConsumer.acknowledge(ProviderConstants.ACK_TYPE ackType)
Called to acknowledge all messages that have been marked as delivered but
have not yet been marked consumed.
|
Modifier and Type | Method and Description |
---|---|
void |
FailoverProvider.acknowledge(JmsInboundMessageDispatch envelope,
ProviderConstants.ACK_TYPE ackType,
AsyncResult request) |
void |
FailoverProvider.acknowledge(JmsSessionId sessionId,
ProviderConstants.ACK_TYPE ackType,
AsyncResult request) |
Copyright © 2013–2016 The Apache Software Foundation. All rights reserved.