Package | Description |
---|---|
org.apache.activemq.advisory |
Support for JMS Advisory messages as well as some helper listeners to listen to the clients, producers and consumers available.
|
org.apache.activemq.console.filter | |
org.apache.activemq.store |
The APIs which need to be implemented for persistent message stores for durable messaging
|
org.apache.activemq.store.amq |
The default Store implementation for ActiveMQ
|
org.apache.activemq.store.jdbc |
Message persistence implemented using JDBC
|
org.apache.activemq.store.journal |
Message persistence using a high performance transaction log via the Journal interface.
|
org.apache.activemq.store.kahadaptor |
kaha implementation of message persistence for the broker
|
org.apache.activemq.store.kahadb | |
org.apache.activemq.store.memory |
VM based implementation of message persistence
|
Modifier and Type | Method and Description |
---|---|
java.util.Set<ActiveMQQueue> |
DestinationSource.getQueues()
Returns the current queues available on the broker
|
Modifier and Type | Method and Description |
---|---|
protected java.util.List |
AmqMessagesQueryFilter.queryMessages(ActiveMQQueue queue,
java.lang.String selector)
Query the messages of a queue destination using a queue browser
|
Modifier and Type | Method and Description |
---|---|
MessageStore |
PersistenceAdapter.createQueueMessageStore(ActiveMQQueue destination)
Factory method to create a new queue message store with the given destination name
|
ReferenceStore |
ReferenceStoreAdapter.createQueueReferenceStore(ActiveMQQueue destination)
Factory method to create a new queue message store with the given
destination name
|
void |
PersistenceAdapter.removeQueueMessageStore(ActiveMQQueue destination)
Cleanup method to remove any state associated with the given destination.
|
Modifier and Type | Method and Description |
---|---|
MessageStore |
AMQPersistenceAdapter.createQueueMessageStore(ActiveMQQueue destination) |
void |
AMQPersistenceAdapter.removeQueueMessageStore(ActiveMQQueue destination)
Cleanup method to remove any state associated with the given destination
|
Modifier and Type | Method and Description |
---|---|
MessageStore |
JDBCPersistenceAdapter.createQueueMessageStore(ActiveMQQueue destination) |
void |
JDBCPersistenceAdapter.removeQueueMessageStore(ActiveMQQueue destination)
Cleanup method to remove any state associated with the given destination
No state retained....
|
Modifier and Type | Method and Description |
---|---|
MessageStore |
JournalPersistenceAdapter.createQueueMessageStore(ActiveMQQueue destination) |
void |
JournalPersistenceAdapter.removeQueueMessageStore(ActiveMQQueue destination)
Cleanup method to remove any state associated with the given destination
|
Modifier and Type | Field and Description |
---|---|
protected java.util.concurrent.ConcurrentHashMap<ActiveMQQueue,MessageStore> |
KahaPersistenceAdapter.queues |
Modifier and Type | Method and Description |
---|---|
MessageStore |
KahaPersistenceAdapter.createQueueMessageStore(ActiveMQQueue destination) |
MessageStore |
KahaReferenceStoreAdapter.createQueueMessageStore(ActiveMQQueue destination) |
ReferenceStore |
KahaReferenceStoreAdapter.createQueueReferenceStore(ActiveMQQueue destination) |
void |
KahaPersistenceAdapter.removeQueueMessageStore(ActiveMQQueue destination)
Cleanup method to remove any state associated with the given destination
|
Modifier and Type | Method and Description |
---|---|
MessageStore |
TempKahaDBStore.createQueueMessageStore(ActiveMQQueue destination) |
MessageStore |
KahaDBPersistenceAdapter.createQueueMessageStore(ActiveMQQueue destination) |
MessageStore |
KahaDBStore.createQueueMessageStore(ActiveMQQueue destination) |
void |
TempKahaDBStore.removeQueueMessageStore(ActiveMQQueue destination)
Cleanup method to remove any state associated with the given destination.
|
void |
KahaDBPersistenceAdapter.removeQueueMessageStore(ActiveMQQueue destination) |
void |
KahaDBStore.removeQueueMessageStore(ActiveMQQueue destination)
Cleanup method to remove any state associated with the given destination.
|
Modifier and Type | Method and Description |
---|---|
MessageStore |
MemoryPersistenceAdapter.createQueueMessageStore(ActiveMQQueue destination) |
void |
MemoryPersistenceAdapter.removeQueueMessageStore(ActiveMQQueue destination)
Cleanup method to remove any state associated with the given destination
|
Copyright © 2005-2012. All Rights Reserved.