|
||||||||||
PREV NEXT | FRAMES NO FRAMES |
Packages that use Store | |
---|---|
org.apache.activemq.broker | The core classes for the ActiveMQ Message Broker and its connectors. |
org.apache.activemq.broker.region | Region abstraction and implementations in the Broker. |
org.apache.activemq.broker.region.cursors | |
org.apache.activemq.broker.region.policy | The policies which can be associated with a particular destination or wildcard. |
org.apache.activemq.kaha | fast message persistence implementation |
org.apache.activemq.kaha.impl | |
org.apache.activemq.store.kahadaptor | kaha implementation of message persistence for the broker |
org.apache.activemq.store.rapid |
Uses of Store in org.apache.activemq.broker |
---|
Methods in org.apache.activemq.broker that return Store | |
---|---|
Store |
BrokerService.getTempDataStore()
|
Store |
Broker.getTempDataStore()
|
Store |
MutableBrokerFilter.getTempDataStore()
|
Store |
BrokerFilter.getTempDataStore()
|
Store |
ErrorBroker.getTempDataStore()
|
Store |
EmptyBroker.getTempDataStore()
|
Methods in org.apache.activemq.broker with parameters of type Store | |
---|---|
void |
BrokerService.setTempDataStore(Store tempDataStore)
|
Uses of Store in org.apache.activemq.broker.region |
---|
Methods in org.apache.activemq.broker.region that return Store | |
---|---|
Store |
RegionBroker.getTempDataStore()
|
Uses of Store in org.apache.activemq.broker.region.cursors |
---|
Constructors in org.apache.activemq.broker.region.cursors with parameters of type Store | |
---|---|
FilePendingMessageCursor(java.lang.String name,
Store store)
|
|
StoreDurableSubscriberCursor(java.lang.String clientId,
java.lang.String subscriberName,
Store store,
int maxBatchSize)
|
Uses of Store in org.apache.activemq.broker.region.policy |
---|
Methods in org.apache.activemq.broker.region.policy with parameters of type Store | |
---|---|
PendingMessageCursor |
PendingDurableSubscriberMessageStoragePolicy.getSubscriberPendingMessageCursor(java.lang.String clientId,
java.lang.String name,
Store tmpStorage,
int maxBatchSize)
Retrieve the configured pending message storage cursor; |
PendingMessageCursor |
FilePendingDurableSubscriberMessageStoragePolicy.getSubscriberPendingMessageCursor(java.lang.String clientId,
java.lang.String name,
Store tmpStorage,
int maxBatchSize)
Retrieve the configured pending message storage cursor; |
PendingMessageCursor |
StorePendingDurableSubscriberMessageStoragePolicy.getSubscriberPendingMessageCursor(java.lang.String clientId,
java.lang.String name,
Store tmpStorage,
int maxBatchSize)
Retrieve the configured pending message storage cursor; |
PendingMessageCursor |
VMPendingDurableSubscriberMessageStoragePolicy.getSubscriberPendingMessageCursor(java.lang.String clientId,
java.lang.String name,
Store tmpStorage,
int maxBatchSize)
Retrieve the configured pending message storage cursor; |
Uses of Store in org.apache.activemq.kaha |
---|
Methods in org.apache.activemq.kaha that return Store | |
---|---|
static Store |
StoreFactory.open(java.lang.String name,
java.lang.String mode)
open or create a Store |
Uses of Store in org.apache.activemq.kaha.impl |
---|
Classes in org.apache.activemq.kaha.impl that implement Store | |
---|---|
class |
KahaStore
Store Implementation |
Uses of Store in org.apache.activemq.store.kahadaptor |
---|
Methods in org.apache.activemq.store.kahadaptor that return Store | |
---|---|
protected Store |
KahaPersistenceAdapter.getStore()
|
Constructors in org.apache.activemq.store.kahadaptor with parameters of type Store | |
---|---|
KahaTopicMessageStore(Store store,
ListContainer messageContainer,
ListContainer ackContainer,
MapContainer subsContainer,
ActiveMQDestination destination)
|
Uses of Store in org.apache.activemq.store.rapid |
---|
Methods in org.apache.activemq.store.rapid that return Store | |
---|---|
Store |
RapidPersistenceAdapter.getStore()
|
|
||||||||||
PREV NEXT | FRAMES NO FRAMES |