| Package | Description |
|---|---|
| org.apache.activemq.broker.region |
Region abstraction and implementations in the Broker.
|
| org.apache.activemq.broker.region.cursors |
Cursors used to page persistent messages into the broker from the store
|
| Modifier and Type | Class and Description |
|---|---|
class |
IndirectMessageReference
Keeps track of a message that is flowing through the Broker.
|
| Modifier and Type | Field and Description |
|---|---|
static QueueMessageReference |
QueueMessageReference.NULL_MESSAGE |
| Modifier and Type | Method and Description |
|---|---|
QueueMessageReference |
Queue.getMessage(String id) |
| Modifier and Type | Method and Description |
|---|---|
protected boolean |
Queue.assignMessageGroup(Subscription subscription,
QueueMessageReference node) |
boolean |
Queue.moveMessageTo(ConnectionContext context,
QueueMessageReference m,
ActiveMQDestination dest)
Move a message
|
protected void |
Queue.removeMessage(ConnectionContext c,
QueueMessageReference r) |
protected void |
Queue.removeMessage(ConnectionContext c,
Subscription subs,
QueueMessageReference r) |
protected void |
Queue.removeMessage(ConnectionContext context,
Subscription sub,
QueueMessageReference reference,
MessageAck ack) |
| Modifier and Type | Method and Description |
|---|---|
void |
QueueDispatchPendingList.addMessageForRedelivery(QueueMessageReference qmr) |
Copyright © 2005–2015 FuseSource, Corp.. All rights reserved.