Package | Description |
---|---|
org.apache.activemq.broker |
The core classes for the ActiveMQ Message Broker and its connectors.
|
org.apache.activemq.broker.inteceptor |
MessageInteceptor malarky
|
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.broker.scheduler |
The Message Scheduler for delayed (or scheduled) message delivery
|
org.apache.activemq.broker.view |
Broker Plugins for visualising the current system
|
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.transport | |
org.apache.activemq.transport.vm |
In-JVM based Transport implementation.
|
org.apache.activemq.util |
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 | Field and Description |
---|---|
protected BrokerService |
TransportConnection.brokerService |
protected BrokerService |
LockableServiceSupport.brokerService |
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
|
BrokerService |
DefaultBrokerFactory.createBroker(URI brokerURI) |
static BrokerService |
BrokerFactory.createBroker(URI brokerURI)
Creates a broker from a URI configuration
|
BrokerService |
PropertiesBrokerFactory.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<Object,Object> properties) |
BrokerService |
BrokerRegistry.findFirst()
Returns the first registered broker found
|
BrokerService |
LockableServiceSupport.getBrokerService() |
BrokerService |
MutableBrokerFilter.getBrokerService() |
BrokerService |
Broker.getBrokerService() |
BrokerService |
BrokerFilter.getBrokerService() |
BrokerService |
EmptyBroker.getBrokerService() |
BrokerService |
ErrorBroker.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 |
LockableServiceSupport.setBrokerService(BrokerService brokerService) |
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 |
---|---|
MessageInterceptorRegistry |
MessageInterceptorRegistry.get(BrokerService brokerService) |
Modifier and Type | Field and Description |
---|---|
protected BrokerService |
DurableSubscriptionView.brokerService |
Constructor and Description |
---|
BrokerView(BrokerService brokerService,
ManagedRegionBroker managedBroker) |
DurableSubscriptionView(ManagedRegionBroker broker,
BrokerService brokerService,
String clientId,
String userName,
Subscription sub)
Constructor
|
InactiveDurableSubscriptionView(ManagedRegionBroker broker,
BrokerService brokerService,
String clientId,
SubscriptionInfo subInfo,
Subscription subscription)
Constructor
|
ManagedRegionBroker(BrokerService brokerService,
ManagementContext context,
ObjectName brokerObjectName,
TaskRunnerFactory taskRunnerFactory,
SystemUsage memoryManager,
DestinationFactory destinationFactory,
DestinationInterceptor destinationInterceptor,
Scheduler scheduler,
ThreadPoolExecutor executor) |
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) |
Constructor and Description |
---|
SchedulerBroker(BrokerService brokerService,
Broker next,
JobSchedulerStore store) |
Modifier and Type | Method and Description |
---|---|
BrokerService |
MessageBrokerView.getBrokerService() |
Constructor and Description |
---|
MessageBrokerView(BrokerService brokerService)
Create a view of a running Broker
|
Modifier and Type | Field and Description |
---|---|
protected BrokerService |
DemandForwardingBridgeSupport.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 |
---|
MBeanBridgeDestination(BrokerService brokerService,
NetworkBridgeConfiguration networkBridgeConfiguration,
NetworkBridge bridge,
NetworkBridgeView networkBridgeView) |
MBeanNetworkListener(BrokerService brokerService,
NetworkBridgeConfiguration networkBridgeConfiguration,
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 |
---|---|
static TransportServer |
TransportFactorySupport.bind(BrokerService brokerService,
URI location) |
Modifier and Type | Field and Description |
---|---|
static ConcurrentMap<String,BrokerService> |
VMTransportFactory.BROKERS |
Modifier and Type | Field and Description |
---|---|
protected BrokerService |
DefaultIOExceptionHandler.broker |
Modifier and Type | Method and Description |
---|---|
void |
DefaultIOExceptionHandler.setBrokerService(BrokerService broker) |
Copyright © 2005–2019 FuseSource, Corp.. All rights reserved.