Package | Description |
---|---|
org.apache.activemq.advisory |
Support for JMS Advisory messages as well as some helper listeners to listen to the clients, producers and consumers available.
|
org.apache.activemq.broker |
The core classes for the ActiveMQ Message Broker and its connectors.
|
org.apache.activemq.broker.cluster | |
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.cursors |
Cursors used to page persistent messages into the broker from the store
|
org.apache.activemq.broker.region.policy |
The policies which can be associated with a particular destination or wildcard.
|
org.apache.activemq.broker.region.virtual |
Implementation classes for Virtual Destinations
|
org.apache.activemq.broker.scheduler | |
org.apache.activemq.broker.util |
Some utility Broker Plugins
|
org.apache.activemq.broker.view |
Broker Plugins for visualising the current system
|
org.apache.activemq.plugin | |
org.apache.activemq.security |
Plugable Security Adapter framework along with default implementations such as the JAAS implementation.
|
org.apache.activemq.util |
Some utility classes
|
Modifier and Type | Class and Description |
---|---|
class |
AdvisoryBroker
This broker filter handles tracking the state of the broker for purposes of
publishing advisory messages to advisory consumers.
|
Constructor and Description |
---|
AdvisoryBroker(Broker next) |
Modifier and Type | Class and Description |
---|---|
class |
BrokerBroadcaster
Used to add listeners for Broker actions
|
class |
BrokerFilter
Allows you to intercept broker operation so that features such as security
can be implemented as a pluggable filter.
|
class |
BrokerPluginSupport
A useful base class for implementing broker plugins.
|
class |
CompositeDestinationBroker
This broker filter handles composite destinations.
|
class |
EmptyBroker
Dumb implementation - used to be overriden by listeners
|
class |
ErrorBroker
Implementation of the broker where all it's methods throw an
BrokerStoppedException.
|
class |
InsertableMutableBrokerFilter
Inserts itself into the BrokerStack
|
class |
MutableBrokerFilter
Like a BrokerFilter but it allows you to switch the getNext().broker.
|
class |
TransactionBroker
This broker filter handles the transaction related operations in the Broker
interface.
|
class |
UserIDBroker
This broker filter will append the producer's user ID into the JMSXUserID header
to allow folks to know reliably who the user was who produced a message.
|
Modifier and Type | Field and Description |
---|---|
protected Broker |
TransportConnection.broker |
protected Broker[] |
BrokerBroadcaster.listeners |
protected Broker |
BrokerFilter.next |
Modifier and Type | Field and Description |
---|---|
protected AtomicReference<Broker> |
MutableBrokerFilter.next |
Modifier and Type | Method and Description |
---|---|
protected Broker |
BrokerService.addInterceptors(Broker broker)
Strategy method to add interceptors to the broker
|
protected Broker |
BrokerService.createBroker()
Factory method to create a new broker
|
protected Broker |
BrokerService.createRegionBroker()
Factory method to create the core region broker onto which interceptors
are added
|
protected Broker |
BrokerService.createRegionBroker(DestinationInterceptor destinationInterceptor) |
Broker |
Broker.getAdaptor(Class type)
Get a Broker from the Broker Stack that is a particular class
|
Broker |
EmptyBroker.getAdaptor(Class type) |
Broker |
MutableBrokerFilter.getAdaptor(Class type) |
Broker |
BrokerFilter.getAdaptor(Class type) |
Broker |
ErrorBroker.getAdaptor(Class type) |
Broker |
BrokerService.getBroker()
Returns the message broker
|
Broker |
ConnectionContext.getBroker() |
Broker |
TransportConnector.getBroker() |
protected Broker[] |
BrokerBroadcaster.getListeners() |
Broker |
MutableBrokerFilter.getNext() |
Broker |
BrokerService.getRegionBroker() |
Broker |
Broker.getRoot()
Ensure we get the Broker at the top of the Stack
|
Broker |
EmptyBroker.getRoot() |
Broker |
MutableBrokerFilter.getRoot() |
Broker |
BrokerFilter.getRoot() |
Broker |
ErrorBroker.getRoot() |
Broker |
BrokerPlugin.installPlugin(Broker broker)
Installs the plugin into the interceptor chain of the broker, returning the new
intercepted broker to use.
|
Broker |
BrokerPluginSupport.installPlugin(Broker broker) |
Modifier and Type | Method and Description |
---|---|
protected List<Broker> |
BrokerBroadcaster.getListenersAsList() |
Modifier and Type | Method and Description |
---|---|
protected Broker |
BrokerService.addInterceptors(Broker broker)
Strategy method to add interceptors to the broker
|
void |
BrokerBroadcaster.addListener(Broker broker) |
Broker |
BrokerPlugin.installPlugin(Broker broker)
Installs the plugin into the interceptor chain of the broker, returning the new
intercepted broker to use.
|
Broker |
BrokerPluginSupport.installPlugin(Broker broker) |
void |
BrokerBroadcaster.removeListener(Broker broker) |
void |
ConnectionContext.setBroker(Broker broker) |
void |
MutableBrokerFilter.setNext(Broker next) |
void |
BrokerService.setRegionBroker(Broker regionBroker) |
Constructor and Description |
---|
BrokerBroadcaster(Broker next) |
BrokerFilter(Broker next) |
CompositeDestinationBroker(Broker next) |
MutableBrokerFilter(Broker next) |
TransactionBroker(Broker next,
TransactionStore transactionStore) |
TransportConnection(TransportConnector connector,
Transport transport,
Broker broker,
TaskRunnerFactory taskRunnerFactory) |
UserIDBroker(Broker next) |
Modifier and Type | Class and Description |
---|---|
class |
ConnectionSplitBroker
Monitors for client connections that may fail to another broker - but this
broker isn't aware they've gone.
|
Constructor and Description |
---|
ConnectionSplitBroker(Broker next) |
Modifier and Type | Class and Description |
---|---|
class |
MasterBroker
The Message Broker which passes messages to a slave
|
Modifier and Type | Class and Description |
---|---|
class |
ManagedRegionBroker |
Modifier and Type | Method and Description |
---|---|
Broker |
ManagedRegionBroker.getContextBroker() |
Modifier and Type | Method and Description |
---|---|
void |
ManagedRegionBroker.setContextBroker(Broker contextBroker) |
Constructor and Description |
---|
ManagedTransportConnection(TransportConnector connector,
Transport transport,
Broker broker,
TaskRunnerFactory factory,
ManagementContext context,
ObjectName connectorName) |
Modifier and Type | Class and Description |
---|---|
class |
RegionBroker
Routes Broker operations to the correct messaging regions for processing.
|
Modifier and Type | Field and Description |
---|---|
protected Broker |
BaseDestination.broker |
protected Broker |
AbstractSubscription.broker |
protected Broker |
BaseDestination.regionBroker |
Modifier and Type | Method and Description |
---|---|
Broker |
RegionBroker.getAdaptor(Class type) |
Broker |
RegionBroker.getRoot() |
Modifier and Type | Method and Description |
---|---|
void |
DestinationInterceptor.create(Broker broker,
ConnectionContext context,
ActiveMQDestination destination) |
void |
CompositeDestinationInterceptor.create(Broker broker,
ConnectionContext context,
ActiveMQDestination destination) |
Constructor and Description |
---|
AbstractSubscription(Broker broker,
ConnectionContext context,
ConsumerInfo info) |
DurableTopicSubscription(Broker broker,
SystemUsage usageManager,
ConnectionContext context,
ConsumerInfo info,
boolean keepDurableSubsActive) |
PrefetchSubscription(Broker broker,
SystemUsage usageManager,
ConnectionContext context,
ConsumerInfo info) |
PrefetchSubscription(Broker broker,
SystemUsage usageManager,
ConnectionContext context,
ConsumerInfo info,
PendingMessageCursor cursor) |
QueueBrowserSubscription(Broker broker,
SystemUsage usageManager,
ConnectionContext context,
ConsumerInfo info) |
QueueSubscription(Broker broker,
SystemUsage usageManager,
ConnectionContext context,
ConsumerInfo info) |
TopicSubscription(Broker broker,
ConnectionContext context,
ConsumerInfo info,
SystemUsage usageManager) |
Modifier and Type | Field and Description |
---|---|
protected Broker |
FilePendingMessageCursor.broker |
Modifier and Type | Method and Description |
---|---|
static boolean |
AbstractPendingMessageCursor.isPrioritizedMessageSubscriber(Broker broker,
Subscription sub) |
Constructor and Description |
---|
FilePendingMessageCursor(Broker broker,
String name,
boolean prioritizedMessages) |
StoreDurableSubscriberCursor(Broker broker,
String clientId,
String subscriberName,
int maxBatchSize,
DurableTopicSubscription subscription) |
StoreQueueCursor(Broker broker,
Queue queue)
Construct
|
Modifier and Type | Method and Description |
---|---|
void |
PolicyEntry.baseConfiguration(Broker broker,
BaseDestination destination) |
void |
PolicyEntry.configure(Broker broker,
Queue queue) |
void |
PolicyEntry.configure(Broker broker,
SystemUsage memoryManager,
DurableTopicSubscription sub) |
void |
PolicyEntry.configure(Broker broker,
SystemUsage memoryManager,
QueueBrowserSubscription sub) |
void |
PolicyEntry.configure(Broker broker,
SystemUsage memoryManager,
QueueSubscription sub) |
void |
PolicyEntry.configure(Broker broker,
SystemUsage memoryManager,
TopicSubscription subscription) |
void |
PolicyEntry.configure(Broker broker,
Topic topic) |
PendingMessageCursor |
PendingQueueMessageStoragePolicy.getQueuePendingMessageCursor(Broker broker,
Queue queue)
Retrieve the configured pending message storage cursor;
|
PendingMessageCursor |
FilePendingQueueMessageStoragePolicy.getQueuePendingMessageCursor(Broker broker,
Queue queue) |
PendingMessageCursor |
VMPendingQueueMessageStoragePolicy.getQueuePendingMessageCursor(Broker broker,
Queue queue) |
PendingMessageCursor |
StorePendingQueueMessageStoragePolicy.getQueuePendingMessageCursor(Broker broker,
Queue queue) |
PendingMessageCursor |
PendingSubscriberMessageStoragePolicy.getSubscriberPendingMessageCursor(Broker broker,
String name,
int maxBatchSize,
Subscription subs)
Retrieve the configured pending message storage cursor;
|
PendingMessageCursor |
FilePendingSubscriberMessageStoragePolicy.getSubscriberPendingMessageCursor(Broker broker,
String name,
int maxBatchSize,
Subscription subs) |
PendingMessageCursor |
VMPendingSubscriberMessageStoragePolicy.getSubscriberPendingMessageCursor(Broker broker,
String name,
int maxBatchSize,
Subscription subs) |
PendingMessageCursor |
PendingDurableSubscriberMessageStoragePolicy.getSubscriberPendingMessageCursor(Broker broker,
String clientId,
String name,
int maxBatchSize,
DurableTopicSubscription sub)
Retrieve the configured pending message storage cursor;
|
PendingMessageCursor |
StorePendingDurableSubscriberMessageStoragePolicy.getSubscriberPendingMessageCursor(Broker broker,
String clientId,
String name,
int maxBatchSize,
DurableTopicSubscription sub)
Retrieve the configured pending message storage cursor;
|
PendingMessageCursor |
VMPendingDurableSubscriberMessageStoragePolicy.getSubscriberPendingMessageCursor(Broker broker,
String clientId,
String name,
int maxBatchSize,
DurableTopicSubscription sub)
Retrieve the configured pending message storage cursor;
|
PendingMessageCursor |
FilePendingDurableSubscriberMessageStoragePolicy.getSubscriberPendingMessageCursor(Broker broker,
String clientId,
String name,
int maxBatchSize,
DurableTopicSubscription sub)
Retrieve the configured pending message storage cursor;
|
void |
SubscriptionRecoveryPolicy.setBroker(Broker broker) |
void |
LastImageSubscriptionRecoveryPolicy.setBroker(Broker broker) |
void |
FixedCountSubscriptionRecoveryPolicy.setBroker(Broker broker) |
void |
TimedSubscriptionRecoveryPolicy.setBroker(Broker broker) |
void |
QueryBasedSubscriptionRecoveryPolicy.setBroker(Broker broker) |
void |
FixedSizedSubscriptionRecoveryPolicy.setBroker(Broker broker) |
void |
NoSubscriptionRecoveryPolicy.setBroker(Broker broker) |
void |
SlowConsumerStrategy.setBrokerService(Broker broker) |
void |
AbortSlowConsumerStrategy.setBrokerService(Broker broker) |
Modifier and Type | Method and Description |
---|---|
void |
MirroredQueue.create(Broker broker,
ConnectionContext context,
ActiveMQDestination destination) |
void |
CompositeDestination.create(Broker broker,
ConnectionContext context,
ActiveMQDestination destination) |
void |
VirtualDestinationInterceptor.create(Broker broker,
ConnectionContext context,
ActiveMQDestination destination) |
void |
VirtualTopic.create(Broker broker,
ConnectionContext context,
ActiveMQDestination destination) |
Modifier and Type | Class and Description |
---|---|
class |
SchedulerBroker |
Constructor and Description |
---|
SchedulerBroker(Broker next,
File directory) |
Modifier and Type | Class and Description |
---|---|
class |
DestinationPathSeparatorBroker |
class |
LoggingBrokerPlugin
A simple Broker intercepter which allows you to enable/disable logging.
|
class |
MulticastTraceBrokerPlugin
A Broker interceptor which allows you to trace all operations to a Multicast
socket.
|
class |
TimeStampingBrokerPlugin
A Broker interceptor which updates a JMS Client's timestamp on the message
with a broker timestamp.
|
class |
TraceBrokerPathPlugin
The TraceBrokerPathPlugin can be used in a network of Brokers.
|
class |
UDPTraceBrokerPlugin
A Broker interceptor which allows you to trace all operations to a UDP
socket.
|
Modifier and Type | Class and Description |
---|---|
class |
ConnectionDotFileInterceptor |
class |
DestinationDotFileInterceptor |
class |
DotFileInterceptorSupport
Useful base class
|
Modifier and Type | Method and Description |
---|---|
Broker |
DestinationDotFilePlugin.installPlugin(Broker broker) |
Broker |
ConnectionDotFilePlugin.installPlugin(Broker broker) |
Modifier and Type | Method and Description |
---|---|
Broker |
DestinationDotFilePlugin.installPlugin(Broker broker) |
Broker |
ConnectionDotFilePlugin.installPlugin(Broker broker) |
Constructor and Description |
---|
ConnectionDotFileInterceptor(Broker next,
String file,
boolean redrawOnRemove) |
DestinationDotFileInterceptor(Broker next,
String file) |
DotFileInterceptorSupport(Broker next,
String file) |
Modifier and Type | Class and Description |
---|---|
class |
DiscardingDLQBroker |
class |
ForcePersistencyModeBroker
A Plugin which allows to force every incoming message to be PERSISTENT or NON-PERSISTENT.
|
class |
StatisticsBroker
A StatisticsBroker You can retrieve a Map Message for a Destination - or
Broker containing statistics as key-value pairs The message must contain a
replyTo Destination - else its ignored
|
class |
SubQueueSelectorCacheBroker
A plugin which allows the caching of the selector from a subscription queue.
|
Modifier and Type | Method and Description |
---|---|
Broker |
StatisticsBrokerPlugin.installPlugin(Broker broker) |
Broker |
DiscardingDLQBrokerPlugin.installPlugin(Broker broker)
Installs the plugin into the interceptor chain of the broker, returning the new intercepted broker to use.
|
Broker |
SubQueueSelectorCacheBrokerPlugin.installPlugin(Broker broker) |
Broker |
ForcePersistencyModeBrokerPlugin.installPlugin(Broker broker) |
Modifier and Type | Method and Description |
---|---|
Broker |
StatisticsBrokerPlugin.installPlugin(Broker broker) |
Broker |
DiscardingDLQBrokerPlugin.installPlugin(Broker broker)
Installs the plugin into the interceptor chain of the broker, returning the new intercepted broker to use.
|
Broker |
SubQueueSelectorCacheBrokerPlugin.installPlugin(Broker broker) |
Broker |
ForcePersistencyModeBrokerPlugin.installPlugin(Broker broker) |
Constructor and Description |
---|
DiscardingDLQBroker(Broker next) |
ForcePersistencyModeBroker(Broker next)
Constructor
|
StatisticsBroker(Broker next)
Constructor
|
SubQueueSelectorCacheBroker(Broker next,
File persistFile)
Constructor
|
Modifier and Type | Class and Description |
---|---|
class |
AuthorizationBroker
Verifies if a authenticated user can do an operation against the broker using
an authorization map.
|
class |
JaasAuthenticationBroker
Logs a user in using JAAS.
|
class |
JaasCertificateAuthenticationBroker
A JAAS Authentication Broker that uses SSL Certificates.
|
class |
JaasDualAuthenticationBroker
A JAAS Authentication Broker that uses different JAAS domain configurations
depending if the connection is over an SSL enabled Connector or not.
|
class |
SimpleAuthenticationBroker
Handles authenticating a users against a simple user name/password map.
|
Modifier and Type | Method and Description |
---|---|
Broker |
AuthorizationPlugin.installPlugin(Broker broker) |
Broker |
JaasDualAuthenticationPlugin.installPlugin(Broker broker) |
Broker |
JaasAuthenticationPlugin.installPlugin(Broker broker) |
Broker |
JaasCertificateAuthenticationPlugin.installPlugin(Broker broker) |
Broker |
SimpleAuthenticationPlugin.installPlugin(Broker parent) |
Modifier and Type | Method and Description |
---|---|
Broker |
AuthorizationPlugin.installPlugin(Broker broker) |
Broker |
JaasDualAuthenticationPlugin.installPlugin(Broker broker) |
Broker |
JaasAuthenticationPlugin.installPlugin(Broker broker) |
Broker |
JaasCertificateAuthenticationPlugin.installPlugin(Broker broker) |
Broker |
SimpleAuthenticationPlugin.installPlugin(Broker parent) |
Constructor and Description |
---|
AuthorizationBroker(Broker next,
AuthorizationMap authorizationMap) |
JaasAuthenticationBroker(Broker next,
String jassConfiguration) |
JaasCertificateAuthenticationBroker(Broker next,
String jaasConfiguration)
Simple constructor.
|
JaasDualAuthenticationBroker(Broker next,
String jaasConfiguration,
String jaasSslConfiguration)
Simple constructor.
|
SimpleAuthenticationBroker(Broker next,
Map<String,String> userPasswords,
Map<String,Set<Principal>> userGroups) |
Modifier and Type | Method and Description |
---|---|
protected static ConnectionContext |
BrokerSupport.createAdminConnectionContext(Broker broker)
Factory method to create the new administration connection context
object.
|
static ConnectionContext |
BrokerSupport.getConnectionContext(Broker broker)
Returns the broker's administration connection context used for
configuring the broker at startup
|
Copyright © 2005–2016 The Apache Software Foundation. All rights reserved.