Package | Description |
---|---|
org.apache.activemq.broker.jmx |
JMX MBeans for the broker and its core connectors.
|
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
|
org.apache.activemq.broker.region.policy |
The policies which can be associated with a particular destination or wildcard.
|
Constructor and Description |
---|
QueueView(ManagedRegionBroker broker,
Queue destination) |
Modifier and Type | Class and Description |
---|---|
class |
TempQueue
The Queue is a List of MessageEntry objects that are dispatched to matching
subscriptions.
|
Modifier and Type | Method and Description |
---|---|
protected void |
DestinationFactoryImpl.configureQueue(Queue queue,
ActiveMQDestination destination) |
Constructor and Description |
---|
StoreQueueCursor(Broker broker,
Queue queue)
Construct
|
Modifier and Type | Method and Description |
---|---|
void |
PolicyEntry.configure(Broker broker,
Queue queue) |
PendingMessageCursor |
PendingQueueMessageStoragePolicy.getQueuePendingMessageCursor(Broker broker,
Queue queue)
Retrieve the configured pending message storage cursor;
|
PendingMessageCursor |
FilePendingQueueMessageStoragePolicy.getQueuePendingMessageCursor(Broker broker,
Queue queue) |
PendingMessageCursor |
VMPendingQueueMessageStoragePolicy.getQueuePendingMessageCursor(Broker broker,
Queue queue) |
PendingMessageCursor |
StorePendingQueueMessageStoragePolicy.getQueuePendingMessageCursor(Broker broker,
Queue queue) |
void |
PolicyEntry.update(Queue queue) |
void |
PolicyEntry.update(Queue queue,
Set<String> includedProperties)
Update a queue with this policy.
|
Copyright © 2005–2017. All rights reserved.