Package | Description |
---|---|
org.apache.activemq |
The core JMS client API implementation classes.
|
org.apache.activemq.command |
Command objects used via the Command Pattern to communicate among nodes
|
org.apache.activemq.state |
Modifier and Type | Field and Description |
---|---|
protected LinkedList<MessageDispatch> |
ActiveMQMessageConsumer.deliveredMessages |
Modifier and Type | Method and Description |
---|---|
MessageDispatch |
FifoMessageDispatchChannel.dequeue(long timeout) |
MessageDispatch |
SimplePriorityMessageDispatchChannel.dequeue(long timeout) |
MessageDispatch |
MessageDispatchChannel.dequeue(long timeout)
Used to get an enqueued message.
|
MessageDispatch |
FifoMessageDispatchChannel.dequeueNoWait() |
MessageDispatch |
SimplePriorityMessageDispatchChannel.dequeueNoWait() |
MessageDispatch |
MessageDispatchChannel.dequeueNoWait() |
MessageDispatch |
FifoMessageDispatchChannel.peek() |
MessageDispatch |
SimplePriorityMessageDispatchChannel.peek() |
MessageDispatch |
MessageDispatchChannel.peek() |
Modifier and Type | Method and Description |
---|---|
protected LinkedList<MessageDispatch> |
SimplePriorityMessageDispatchChannel.getList(MessageDispatch md) |
List<MessageDispatch> |
ActiveMQSession.getUnconsumedMessages() |
List<MessageDispatch> |
FifoMessageDispatchChannel.removeAll() |
List<MessageDispatch> |
SimplePriorityMessageDispatchChannel.removeAll() |
List<MessageDispatch> |
MessageDispatchChannel.removeAll() |
Modifier and Type | Method and Description |
---|---|
void |
ActiveMQConnectionConsumer.dispatch(MessageDispatch messageDispatch) |
void |
ActiveMQDispatcher.dispatch(MessageDispatch messageDispatch) |
void |
ActiveMQMessageConsumer.dispatch(MessageDispatch md) |
void |
ActiveMQSession.dispatch(MessageDispatch messageDispatch) |
void |
AdvisoryConsumer.dispatch(MessageDispatch md) |
void |
FifoMessageDispatchChannel.enqueue(MessageDispatch message) |
void |
SimplePriorityMessageDispatchChannel.enqueue(MessageDispatch message) |
void |
MessageDispatchChannel.enqueue(MessageDispatch message) |
void |
FifoMessageDispatchChannel.enqueueFirst(MessageDispatch message) |
void |
SimplePriorityMessageDispatchChannel.enqueueFirst(MessageDispatch message) |
void |
MessageDispatchChannel.enqueueFirst(MessageDispatch message) |
protected LinkedList<MessageDispatch> |
SimplePriorityMessageDispatchChannel.getList(MessageDispatch md) |
protected int |
SimplePriorityMessageDispatchChannel.getPriority(MessageDispatch message) |
Constructor and Description |
---|
MessageAck(MessageDispatch md,
byte ackType,
int messageCount) |
Modifier and Type | Method and Description |
---|---|
Response |
CommandVisitorAdapter.processMessageDispatch(MessageDispatch dispatch) |
Response |
CommandVisitor.processMessageDispatch(MessageDispatch dispatch) |
Copyright © 2005–2016 FuseSource, Corp.. All rights reserved.