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.store.kahadb.plist | |
org.apache.activemq.transport |
The core Transport abstraction and support classes
|
org.apache.activemq.transport.mqtt |
A Broker side implementation of the MQTT 3.1 protocol - see http://mqtt.org/
|
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(String brokerURI)
Creates a broker from a URI configuration
|
static BrokerService |
BrokerFactory.createBroker(String brokerURI,
boolean startBroker)
Creates a broker from a URI configuration
|
static BrokerService |
BrokerFactory.createBroker(URI brokerURI)
Creates a broker from a URI configuration
|
BrokerService |
PropertiesBrokerFactory.createBroker(URI brokerURI) |
BrokerService |
DefaultBrokerFactory.createBroker(URI brokerURI) |
BrokerService |
BrokerFactoryHandler.createBroker(URI brokerURI) |
static BrokerService |
BrokerFactory.createBroker(URI brokerURI,
boolean startBroker)
Creates a broker from a URI configuration
|
protected BrokerService |
PropertiesBrokerFactory.createBrokerService(URI brokerURI,
Map properties) |
BrokerService |
BrokerRegistry.findFirst()
Returns the first registered broker found
|
BrokerService |
Broker.getBrokerService() |
BrokerService |
ErrorBroker.getBrokerService() |
BrokerService |
MutableBrokerFilter.getBrokerService() |
BrokerService |
EmptyBroker.getBrokerService() |
BrokerService |
BrokerFilter.getBrokerService() |
BrokerService |
TransportConnector.getBrokerService() |
BrokerService |
BrokerRegistry.lookup(String brokerName) |
Modifier and Type | Method and Description |
---|---|
Map<String,BrokerService> |
BrokerRegistry.getBrokers() |
Modifier and Type | Method and Description |
---|---|
void |
BrokerRegistry.bind(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,
ObjectName brokerObjectName,
TaskRunnerFactory taskRunnerFactory,
SystemUsage memoryManager,
DestinationFactory destinationFactory,
DestinationInterceptor destinationInterceptor,
Scheduler scheduler,
ThreadPoolExecutor executor) |
ManagedTempQueueRegion(ManagedRegionBroker broker,
BrokerService brokerService,
DestinationStatistics destinationStatistics,
SystemUsage memoryManager,
TaskRunnerFactory taskRunnerFactory,
DestinationFactory destinationFactory) |
Modifier and Type | Field and Description |
---|---|
protected BrokerService |
RegionBroker.brokerService |
protected BrokerService |
BaseDestination.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 |
NetworkConnector.setBrokerService(BrokerService brokerService) |
void |
DemandForwardingBridgeSupport.setBrokerService(BrokerService brokerService) |
Constructor and Description |
---|
MBeanNetworkListener(BrokerService brokerService,
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 |
---|---|
BrokerService |
MultiKahaDBPersistenceAdapter.getBrokerService() |
Modifier and Type | Method and Description |
---|---|
void |
MultiKahaDBPersistenceAdapter.setBrokerService(BrokerService brokerService) |
void |
KahaDBPersistenceAdapter.setBrokerService(BrokerService brokerService) |
void |
MessageDatabase.setBrokerService(BrokerService brokerService) |
Modifier and Type | Method and Description |
---|---|
void |
PListStore.setBrokerService(BrokerService brokerService) |
Modifier and Type | Method and Description |
---|---|
static TransportServer |
TransportFactory.bind(BrokerService brokerService,
URI location) |
Modifier and Type | Method and Description |
---|---|
void |
MQTTTransportFactory.setBrokerService(BrokerService brokerService) |
void |
MQTTSslTransportFactory.setBrokerService(BrokerService brokerService) |
void |
MQTTNIOTransportFactory.setBrokerService(BrokerService brokerService) |
Modifier and Type | Method and Description |
---|---|
void |
StompNIOTransportFactory.setBrokerService(BrokerService brokerService) |
void |
StompTransportFactory.setBrokerService(BrokerService brokerService) |
void |
StompSslTransportFactory.setBrokerService(BrokerService brokerService) |
Modifier and Type | Field and Description |
---|---|
static ConcurrentHashMap<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(URI config) |
BrokerService |
BrokerFactoryBean.getBroker() |
Copyright © 2005–2015. All rights reserved.