Package | Description |
---|---|
org.apache.activemq.broker |
The core classes for the ActiveMQ Message Broker and its connectors.
|
org.apache.activemq.broker.ft |
Helper classes for implementing fault tolerance
|
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.virtual |
Implementation classes for Virtual Destinations
|
org.apache.activemq.network |
Support for federated networks of brokers.
|
org.apache.activemq.network.jms |
Support for a federated network using a foreign JMS provider.
|
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.transport |
The core Transport abstraction and support classes
|
org.apache.activemq.transport.stomp |
An implementation of the Stomp protocol which is a simple wire protocol for writing clients for ActiveMQ in different
languages like Ruby, Python, PHP, C etc.
|
org.apache.activemq.transport.vm |
In-JVM based Transport implementation.
|
org.apache.activemq.util |
Some utility classes
|
org.apache.activemq.xbean |
Modifier and Type | Class and Description |
---|---|
class |
SslBrokerService
A BrokerService that allows access to the key and trust managers used by SSL
connections.
|
Modifier and Type | Method and Description |
---|---|
static BrokerService |
BrokerFactory.createBroker(java.lang.String brokerURI)
Creates a broker from a URI configuration
|
static BrokerService |
BrokerFactory.createBroker(java.lang.String brokerURI,
boolean startBroker)
Creates a broker from a URI configuration
|
BrokerService |
PropertiesBrokerFactory.createBroker(java.net.URI brokerURI) |
BrokerService |
DefaultBrokerFactory.createBroker(java.net.URI brokerURI) |
static BrokerService |
BrokerFactory.createBroker(java.net.URI brokerURI)
Creates a broker from a URI configuration
|
BrokerService |
BrokerFactoryHandler.createBroker(java.net.URI brokerURI) |
static BrokerService |
BrokerFactory.createBroker(java.net.URI brokerURI,
boolean startBroker)
Creates a broker from a URI configuration
|
protected BrokerService |
PropertiesBrokerFactory.createBrokerService(java.net.URI brokerURI,
java.util.Map properties) |
BrokerService |
BrokerRegistry.findFirst()
Returns the first registered broker found
|
BrokerService |
ErrorBroker.getBrokerService() |
BrokerService |
MutableBrokerFilter.getBrokerService() |
BrokerService |
TransportConnector.getBrokerService() |
BrokerService |
BrokerFilter.getBrokerService() |
BrokerService |
EmptyBroker.getBrokerService() |
BrokerService |
Broker.getBrokerService() |
BrokerService |
BrokerRegistry.lookup(java.lang.String brokerName) |
Modifier and Type | Method and Description |
---|---|
java.util.Map<java.lang.String,BrokerService> |
BrokerRegistry.getBrokers() |
Modifier and Type | Method and Description |
---|---|
void |
BrokerRegistry.bind(java.lang.String brokerName,
BrokerService broker) |
void |
BrokerServiceAware.setBrokerService(BrokerService brokerService) |
void |
TransportConnector.setBrokerService(BrokerService brokerService)
This is called by the BrokerService right before it starts the transport.
|
Modifier and Type | Method and Description |
---|---|
void |
MasterConnector.setBrokerService(BrokerService broker) |
Constructor and Description |
---|
BrokerView(BrokerService brokerService,
ManagedRegionBroker managedBroker) |
ManagedRegionBroker(BrokerService brokerService,
ManagementContext context,
javax.management.ObjectName brokerObjectName,
TaskRunnerFactory taskRunnerFactory,
SystemUsage memoryManager,
DestinationFactory destinationFactory,
DestinationInterceptor destinationInterceptor,
Scheduler scheduler,
java.util.concurrent.ThreadPoolExecutor executor) |
ManagedTempQueueRegion(ManagedRegionBroker broker,
BrokerService brokerService,
DestinationStatistics destinationStatistics,
SystemUsage memoryManager,
TaskRunnerFactory taskRunnerFactory,
DestinationFactory destinationFactory) |
Modifier and Type | Field and Description |
---|---|
protected BrokerService |
BaseDestination.brokerService |
protected BrokerService |
RegionBroker.brokerService |
Modifier and Type | Method and Description |
---|---|
BrokerService |
RegionBroker.getBrokerService() |
Modifier and Type | Method and Description |
---|---|
void |
MirroredQueue.setBrokerService(BrokerService brokerService) |
Modifier and Type | Method and Description |
---|---|
BrokerService |
NetworkConnector.getBrokerService() |
Modifier and Type | Method and Description |
---|---|
void |
DemandForwardingBridgeSupport.setBrokerService(BrokerService brokerService) |
void |
NetworkConnector.setBrokerService(BrokerService brokerService) |
Constructor and Description |
---|
MBeanNetworkListener(BrokerService brokerService,
javax.management.ObjectName connectorName) |
Modifier and Type | Method and Description |
---|---|
void |
JmsConnector.setBrokerService(BrokerService service)
One way to configure the local connection - this is called by The
BrokerService when the Connector is embedded
|
Modifier and Type | Method and Description |
---|---|
BrokerService |
AMQPersistenceAdapter.getBrokerService() |
Modifier and Type | Method and Description |
---|---|
void |
AMQPersistenceAdapter.setBrokerService(BrokerService brokerService) |
Modifier and Type | Method and Description |
---|---|
BrokerService |
JDBCPersistenceAdapter.getBrokerService() |
Modifier and Type | Method and Description |
---|---|
void |
JDBCPersistenceAdapter.setBrokerService(BrokerService brokerService) |
Modifier and Type | Method and Description |
---|---|
void |
JournalPersistenceAdapter.setBrokerService(BrokerService brokerService) |
Modifier and Type | Method and Description |
---|---|
void |
KahaPersistenceAdapter.setBrokerService(BrokerService brokerService) |
void |
KahaTransactionStore.setBrokerService(BrokerService brokerService) |
Modifier and Type | Field and Description |
---|---|
protected BrokerService |
MessageDatabase.brokerService |
Modifier and Type | Method and Description |
---|---|
void |
KahaDBPersistenceAdapter.setBrokerService(BrokerService brokerService) |
void |
MessageDatabase.setBrokerService(BrokerService brokerService) |
Modifier and Type | Method and Description |
---|---|
static TransportServer |
TransportFactory.bind(BrokerService brokerService,
java.net.URI location) |
Modifier and Type | Method and Description |
---|---|
void |
StompSslTransportFactory.setBrokerService(BrokerService brokerService) |
void |
StompTransportFactory.setBrokerService(BrokerService brokerService) |
void |
StompNIOTransportFactory.setBrokerService(BrokerService brokerService) |
Modifier and Type | Field and Description |
---|---|
static java.util.concurrent.ConcurrentHashMap<java.lang.String,BrokerService> |
VMTransportFactory.BROKERS |
Modifier and Type | Method and Description |
---|---|
void |
DefaultIOExceptionHandler.setBrokerService(BrokerService broker) |
Modifier and Type | Class and Description |
---|---|
class |
XBeanBrokerService
An ActiveMQ Message Broker.
|
Modifier and Type | Method and Description |
---|---|
BrokerService |
XBeanBrokerFactory.createBroker(java.net.URI config) |
BrokerService |
BrokerFactoryBean.getBroker() |
Copyright © 2005-2012. All Rights Reserved.