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 | |
org.apache.qpid.jms.util |
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) |
void |
JmsMessageConsumer.onInboundMessage(JmsInboundMessageDispatch envelope)
Called from the session when a new Message has been dispatched to this Consumer
from the connection.
|
void |
JmsConnectionListener.onInboundMessage(JmsInboundMessageDispatch envelope)
Called when a Connection is notified that a new Message has arrived for
one of it's currently active subscriptions.
|
void |
JmsMessageDispatcher.onInboundMessage(JmsInboundMessageDispatch envelope)
Called when a new Message delivery is in progress.
|
void |
JmsSession.onInboundMessage(JmsInboundMessageDispatch envelope) |
void |
JmsConnection.onInboundMessage(JmsInboundMessageDispatch envelope) |
protected boolean |
JmsMessageConsumer.redeliveryExceeded(JmsInboundMessageDispatch envelope) |
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 |
DefaultProviderListener.onInboundMessage(JmsInboundMessageDispatch envelope) |
void |
ProviderWrapper.onInboundMessage(JmsInboundMessageDispatch envelope) |
void |
ProviderListener.onInboundMessage(JmsInboundMessageDispatch envelope)
Called when a new Message has arrived for a registered consumer.
|
Modifier and Type | Field and Description |
---|---|
protected Map<JmsInboundMessageDispatch,org.apache.qpid.proton.engine.Delivery> |
AmqpConsumer.delivered |
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) |
protected void |
AmqpConsumer.deliver(JmsInboundMessageDispatch envelope) |
Modifier and Type | Method and Description |
---|---|
void |
FailoverProvider.acknowledge(JmsInboundMessageDispatch envelope,
ProviderConstants.ACK_TYPE ackType,
AsyncResult request) |
void |
FailoverProvider.onInboundMessage(JmsInboundMessageDispatch envelope) |
Modifier and Type | Field and Description |
---|---|
protected LinkedList<JmsInboundMessageDispatch> |
FifoMessageQueue.list |
Modifier and Type | Method and Description |
---|---|
JmsInboundMessageDispatch |
MessageQueue.dequeue(long timeout)
Used to get an enqueued message.
|
JmsInboundMessageDispatch |
AbstractMessageQueue.dequeue(long timeout) |
JmsInboundMessageDispatch |
MessageQueue.dequeueNoWait()
Used to get an enqueued Message if on exists, otherwise returns null.
|
JmsInboundMessageDispatch |
AbstractMessageQueue.dequeueNoWait() |
JmsInboundMessageDispatch |
MessageQueue.peek()
Return but do not remove the first element in the Message queue.
|
JmsInboundMessageDispatch |
AbstractMessageQueue.peek() |
protected JmsInboundMessageDispatch |
PriorityMessageQueue.peekFirst() |
protected abstract JmsInboundMessageDispatch |
AbstractMessageQueue.peekFirst()
Returns but does not remove the first entry in the implementation queue.
|
protected JmsInboundMessageDispatch |
FifoMessageQueue.peekFirst() |
protected JmsInboundMessageDispatch |
PriorityMessageQueue.removeFirst() |
protected abstract JmsInboundMessageDispatch |
AbstractMessageQueue.removeFirst()
Removes and returns the first entry in the implementation queue.
|
protected JmsInboundMessageDispatch |
FifoMessageQueue.removeFirst() |
Modifier and Type | Method and Description |
---|---|
List<JmsInboundMessageDispatch> |
MessageQueue.removeAll()
Removes and returns all Messages in the Queue.
|
List<JmsInboundMessageDispatch> |
PriorityMessageQueue.removeAll() |
List<JmsInboundMessageDispatch> |
FifoMessageQueue.removeAll() |
Modifier and Type | Method and Description |
---|---|
void |
MessageQueue.enqueue(JmsInboundMessageDispatch envelope)
Adds the given message envelope to the end of the Message queue.
|
void |
PriorityMessageQueue.enqueue(JmsInboundMessageDispatch envelope) |
void |
FifoMessageQueue.enqueue(JmsInboundMessageDispatch envelope) |
void |
MessageQueue.enqueueFirst(JmsInboundMessageDispatch envelope)
Adds the given message envelope to the front of the Message queue.
|
void |
PriorityMessageQueue.enqueueFirst(JmsInboundMessageDispatch envelope) |
void |
FifoMessageQueue.enqueueFirst(JmsInboundMessageDispatch envelope) |
Copyright © 2013–2016 The Apache Software Foundation. All rights reserved.