Package | Description |
---|---|
org.apache.activemq.broker |
The core classes for the ActiveMQ Message Broker and its connectors.
|
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.store |
The APIs which need to be implemented for persistent message stores for durable messaging
|
org.apache.activemq.store.kahadb | |
org.apache.activemq.store.memory |
VM based implementation of message persistence
|
org.apache.activemq.usage | |
org.apache.activemq.util |
Modifier and Type | Method and Description |
---|---|
protected PersistenceAdapter |
BrokerService.createPersistenceAdapter() |
PersistenceAdapter |
BrokerService.getPersistenceAdapter() |
protected PersistenceAdapter |
BrokerService.registerPersistenceAdapterMBean(PersistenceAdapter adaptor) |
Modifier and Type | Method and Description |
---|---|
void |
Locker.configure(PersistenceAdapter persistenceAdapter)
Optionally configure the locker with the persistence adapter currently used
You can use persistence adapter configuration details like, data directory
datasource, etc.
|
protected PersistenceAdapter |
BrokerService.registerPersistenceAdapterMBean(PersistenceAdapter adaptor) |
void |
BrokerService.setPersistenceAdapter(PersistenceAdapter persistenceAdapter)
Sets the persistence adaptor implementation to use for this broker
|
protected void |
BrokerService.unregisterPersistenceAdapterMBean(PersistenceAdapter adaptor) |
Constructor and Description |
---|
PersistenceAdapterView(PersistenceAdapter adapter) |
Modifier and Type | Field and Description |
---|---|
protected PersistenceAdapter |
DestinationFactoryImpl.persistenceAdapter |
Modifier and Type | Method and Description |
---|---|
PersistenceAdapter |
DestinationFactoryImpl.getPersistenceAdapter() |
Constructor and Description |
---|
DestinationFactoryImpl(BrokerService brokerService,
TaskRunnerFactory taskRunnerFactory,
PersistenceAdapter persistenceAdapter) |
Modifier and Type | Method and Description |
---|---|
PersistenceAdapter |
PersistenceAdapterFactory.createPersistenceAdapter()
Creates a persistence Adapter that can use a given directory to store it's data.
|
Modifier and Type | Method and Description |
---|---|
void |
SharedFileLocker.configure(PersistenceAdapter persistenceAdapter) |
static List<ActiveMQQueue> |
PersistenceAdapterSupport.listQueues(PersistenceAdapter adapter)
Provides a means of querying the persistence adapter for a list of ActiveMQQueue instances.
|
static List<ActiveMQQueue> |
PersistenceAdapterSupport.listQueues(PersistenceAdapter adapter,
PersistenceAdapterSupport.DestinationMatcher matcher)
Provides a means of querying the persistence adapter for a list of ActiveMQQueue instances
that match some given search criteria.
|
static List<SubscriptionInfo> |
PersistenceAdapterSupport.listSubscriptions(PersistenceAdapter adapter,
String clientId)
Searches the set of subscriptions from the given persistence adapter and returns all those
that belong to the given ClientId value.
|
static List<ActiveMQTopic> |
PersistenceAdapterSupport.listTopics(PersistenceAdapter adapter)
Provides a means of querying the persistence adapter for a list of ActiveMQTopic instances.
|
static List<ActiveMQTopic> |
PersistenceAdapterSupport.listTopics(PersistenceAdapter adapter,
PersistenceAdapterSupport.DestinationMatcher matcher)
Provides a means of querying the persistence adapter for a list of ActiveMQTopic instances
that match some given search criteria.
|
Modifier and Type | Class and Description |
---|---|
class |
KahaDBPersistenceAdapter
An implementation of
PersistenceAdapter designed for use with
KahaDB - Embedded Lightweight Non-Relational Database |
class |
KahaDBStore |
class |
MultiKahaDBPersistenceAdapter
An implementation of
PersistenceAdapter that supports
distribution of destinations across multiple kahaDB persistence adapters |
class |
TempKahaDBStore |
Modifier and Type | Method and Description |
---|---|
PersistenceAdapter |
FilteredKahaDBPersistenceAdapter.getPersistenceAdapter() |
Modifier and Type | Method and Description |
---|---|
List<PersistenceAdapter> |
MultiKahaDBPersistenceAdapter.getAdapters() |
Modifier and Type | Method and Description |
---|---|
void |
FilteredKahaDBPersistenceAdapter.setPersistenceAdapter(PersistenceAdapter persistenceAdapter) |
Constructor and Description |
---|
FilteredKahaDBPersistenceAdapter(ActiveMQDestination destination,
PersistenceAdapter adapter) |
Modifier and Type | Class and Description |
---|---|
class |
MemoryPersistenceAdapter |
Modifier and Type | Field and Description |
---|---|
protected PersistenceAdapter |
MemoryTransactionStore.persistenceAdapter |
Constructor and Description |
---|
MemoryTransactionStore(PersistenceAdapter persistenceAdapter) |
Modifier and Type | Method and Description |
---|---|
PersistenceAdapter |
StoreUsage.getStore() |
Modifier and Type | Method and Description |
---|---|
void |
StoreUsage.setStore(PersistenceAdapter store) |
Constructor and Description |
---|
StoreUsage(String name,
PersistenceAdapter store) |
SystemUsage(String name,
PersistenceAdapter adapter,
PListStore tempStore,
JobSchedulerStore jobSchedulerStore) |
Modifier and Type | Method and Description |
---|---|
PersistenceAdapter |
TransactionTemplate.getPersistenceAdapter() |
Constructor and Description |
---|
TransactionTemplate(PersistenceAdapter persistenceAdapter,
ConnectionContext context) |
Copyright © 2005–2017 The Apache Software Foundation. All rights reserved.