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.store.kahadb | |
org.apache.activemq.store.kahadb.plist | |
org.apache.activemq.transport |
The core Transport abstraction and support classes
|
org.apache.activemq.transport.auto | |
org.apache.activemq.transport.auto.nio | |
org.apache.activemq.transport.mqtt |
A Broker side implementation of the MQTT 3.1 protocol - see http://mqtt.org/
|
org.apache.activemq.transport.mqtt.strategy | |
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 | |
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 | 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 |
PropertiesBrokerFactory.createBroker(URI brokerURI) |
BrokerService |
BrokerFactoryHandler.createBroker(URI brokerURI) |
static BrokerService |
BrokerFactory.createBroker(URI brokerURI)
Creates a broker from a URI configuration
|
BrokerService |
DefaultBrokerFactory.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 |
BrokerFilter.getBrokerService() |
BrokerService |
Broker.getBrokerService() |
BrokerService |
TransportConnector.getBrokerService() |
BrokerService |
EmptyBroker.getBrokerService() |
BrokerService |
MutableBrokerFilter.getBrokerService() |
BrokerService |
ErrorBroker.getBrokerService() |
BrokerService |
LockableServiceSupport.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 |
TransportConnector.setBrokerService(BrokerService brokerService)
This is called by the BrokerService right before it starts the transport.
|
void |
BrokerServiceAware.setBrokerService(BrokerService brokerService) |
void |
LockableServiceSupport.setBrokerService(BrokerService brokerService) |
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 |
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) |
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 | Field and Description |
---|---|
protected BrokerService |
MessageDatabase.brokerService |
Modifier and Type | Method and Description |
---|---|
void |
MessageDatabase.setBrokerService(BrokerService brokerService) |
void |
MultiKahaDBPersistenceAdapter.setBrokerService(BrokerService brokerService) |
void |
KahaDBPersistenceAdapter.setBrokerService(BrokerService brokerService) |
void |
TempKahaDBStore.setBrokerService(BrokerService brokerService) |
Modifier and Type | Method and Description |
---|---|
void |
PListStoreImpl.setBrokerService(BrokerService brokerService) |
Modifier and Type | Method and Description |
---|---|
static TransportServer |
TransportFactorySupport.bind(BrokerService brokerService,
URI location) |
Modifier and Type | Field and Description |
---|---|
protected BrokerService |
AutoTcpTransportServer.brokerService |
protected BrokerService |
AutoTcpTransportFactory.brokerService |
protected BrokerService |
AutoSslTransportFactory.brokerService |
Modifier and Type | Method and Description |
---|---|
void |
AutoTcpTransportFactory.setBrokerService(BrokerService brokerService) |
void |
AutoSslTransportFactory.setBrokerService(BrokerService brokerService) |
Constructor and Description |
---|
AutoSslTransportServer(SslTransportFactory transportFactory,
URI location,
SSLServerSocketFactory serverSocketFactory,
BrokerService brokerService,
Set<String> enabledProtocols) |
AutoTcpTransportServer(TcpTransportFactory transportFactory,
URI location,
ServerSocketFactory serverSocketFactory,
BrokerService brokerService,
Set<String> enabledProtocols) |
Modifier and Type | Field and Description |
---|---|
protected BrokerService |
AutoNioSslTransportFactory.brokerService |
protected BrokerService |
AutoNioTransportFactory.brokerService |
Modifier and Type | Method and Description |
---|---|
void |
AutoNioSslTransportFactory.setBrokerService(BrokerService brokerService) |
void |
AutoNioTransportFactory.setBrokerService(BrokerService brokerService) |
Constructor and Description |
---|
AutoNIOSSLTransportServer(SSLContext context,
TcpTransportFactory transportFactory,
URI location,
ServerSocketFactory serverSocketFactory,
BrokerService brokerService,
Set<String> enabledProtocols) |
Modifier and Type | Method and Description |
---|---|
static MQTTPacketIdGenerator |
MQTTPacketIdGenerator.getMQTTPacketIdGenerator(BrokerService broker) |
void |
MQTTNIOTransportFactory.setBrokerService(BrokerService brokerService) |
void |
MQTTTransportFactory.setBrokerService(BrokerService brokerService) |
void |
MQTTSslTransportFactory.setBrokerService(BrokerService brokerService) |
Constructor and Description |
---|
MQTTProtocolConverter(MQTTTransport mqttTransport,
BrokerService brokerService) |
MQTTTransportFilter(Transport next,
WireFormat wireFormat,
BrokerService brokerService) |
Modifier and Type | Field and Description |
---|---|
protected BrokerService |
AbstractMQTTSubscriptionStrategy.brokerService |
Modifier and Type | Method and Description |
---|---|
void |
AbstractMQTTSubscriptionStrategy.setBrokerService(BrokerService brokerService) |
Modifier and Type | Method and Description |
---|---|
void |
StompNIOTransportFactory.setBrokerService(BrokerService brokerService) |
void |
StompSslTransportFactory.setBrokerService(BrokerService brokerService) |
void |
StompTransportFactory.setBrokerService(BrokerService brokerService) |
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 |
---|---|
static BrokerSubscriptionInfo |
NetworkBridgeUtils.getBrokerSubscriptionInfo(BrokerService brokerService,
NetworkBridgeConfiguration config)
Generate the BrokerSubscriptionInfo which is used to tell the broker on the other
side of the network bridge which NC durable subscriptions are still needed for demand.
|
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–2017 The Apache Software Foundation. All rights reserved.