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.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 |
The Message Scheduler for delayed (or scheduled) message delivery
|
org.apache.activemq.broker.util |
Some utility Broker Plugins
|
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.plugin | |
org.apache.activemq.security |
Plugable Security Adapter framework along with default implementations such as the JAAS implementation.
|
org.apache.activemq.shiro | |
org.apache.activemq.shiro.authc | |
org.apache.activemq.shiro.authz | |
org.apache.activemq.shiro.env | |
org.apache.activemq.shiro.subject | |
org.apache.activemq.util |
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 |
MutableBrokerFilter.getAdaptor(Class type) |
Broker |
BrokerFilter.getAdaptor(Class type) |
Broker |
Broker.getAdaptor(Class type)
Get a Broker from the Broker Stack that is a particular class
|
Broker |
EmptyBroker.getAdaptor(Class type) |
Broker |
ErrorBroker.getAdaptor(Class type) |
Broker |
TransportConnector.getBroker() |
Broker |
ConnectionContext.getBroker() |
Broker |
BrokerService.getBroker()
Returns the message broker
|
protected Broker[] |
BrokerBroadcaster.getListeners() |
Broker |
MutableBrokerFilter.getNext() |
Broker |
BrokerService.getRegionBroker() |
Broker |
MutableBrokerFilter.getRoot() |
Broker |
BrokerFilter.getRoot() |
Broker |
Broker.getRoot()
Ensure we get the Broker at the top of the Stack
|
Broker |
EmptyBroker.getRoot() |
Broker |
ErrorBroker.getRoot() |
Broker |
BrokerPluginSupport.installPlugin(Broker broker) |
Broker |
BrokerPlugin.installPlugin(Broker broker)
Installs the plugin into the interceptor chain of the broker, returning the new
intercepted broker to use.
|
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 |
BrokerPluginSupport.installPlugin(Broker broker) |
Broker |
BrokerPlugin.installPlugin(Broker broker)
Installs the plugin into the interceptor chain of the broker, returning the new
intercepted broker to use.
|
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,
TaskRunnerFactory stopTaskRunnerFactory) |
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 |
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,
TaskRunnerFactory stopFactory,
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 |
AbstractSubscription.broker |
protected Broker |
BaseDestination.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 |
CompositeDestinationInterceptor.create(Broker broker,
ConnectionContext context,
ActiveMQDestination destination) |
void |
DestinationInterceptor.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 | Field and Description |
---|---|
protected Broker |
AbortSlowConsumerStrategy.broker |
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 |
StorePendingQueueMessageStoragePolicy.getQueuePendingMessageCursor(Broker broker,
Queue queue) |
PendingMessageCursor |
FilePendingQueueMessageStoragePolicy.getQueuePendingMessageCursor(Broker broker,
Queue queue) |
PendingMessageCursor |
VMPendingQueueMessageStoragePolicy.getQueuePendingMessageCursor(Broker broker,
Queue queue) |
PendingMessageCursor |
PendingQueueMessageStoragePolicy.getQueuePendingMessageCursor(Broker broker,
Queue queue)
Retrieve the configured pending message storage cursor;
|
PendingMessageCursor |
PendingSubscriberMessageStoragePolicy.getSubscriberPendingMessageCursor(Broker broker,
String name,
int maxBatchSize,
Subscription subs)
Retrieve the configured pending message storage cursor;
|
PendingMessageCursor |
VMPendingSubscriberMessageStoragePolicy.getSubscriberPendingMessageCursor(Broker broker,
String name,
int maxBatchSize,
Subscription subs) |
PendingMessageCursor |
FilePendingSubscriberMessageStoragePolicy.getSubscriberPendingMessageCursor(Broker broker,
String name,
int maxBatchSize,
Subscription subs) |
PendingMessageCursor |
StorePendingDurableSubscriberMessageStoragePolicy.getSubscriberPendingMessageCursor(Broker broker,
String clientId,
String name,
int maxBatchSize,
DurableTopicSubscription sub)
Retrieve the configured pending message storage cursor;
|
PendingMessageCursor |
PendingDurableSubscriberMessageStoragePolicy.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;
|
PendingMessageCursor |
VMPendingDurableSubscriberMessageStoragePolicy.getSubscriberPendingMessageCursor(Broker broker,
String clientId,
String name,
int maxBatchSize,
DurableTopicSubscription sub)
Retrieve the configured pending message storage cursor;
|
void |
FixedSizedSubscriptionRecoveryPolicy.setBroker(Broker broker) |
void |
LastImageSubscriptionRecoveryPolicy.setBroker(Broker broker) |
void |
NoSubscriptionRecoveryPolicy.setBroker(Broker broker) |
void |
QueryBasedSubscriptionRecoveryPolicy.setBroker(Broker broker) |
void |
SubscriptionRecoveryPolicy.setBroker(Broker broker) |
void |
TimedSubscriptionRecoveryPolicy.setBroker(Broker broker) |
void |
RetainedMessageSubscriptionRecoveryPolicy.setBroker(Broker broker) |
void |
FixedCountSubscriptionRecoveryPolicy.setBroker(Broker broker) |
void |
AbortSlowConsumerStrategy.setBrokerService(Broker broker) |
void |
AbortSlowAckConsumerStrategy.setBrokerService(Broker broker) |
void |
SlowConsumerStrategy.setBrokerService(Broker broker)
Sets the Broker instance which can provide a Scheduler among other things.
|
Modifier and Type | Method and Description |
---|---|
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) |
void |
MirroredQueue.create(Broker broker,
ConnectionContext context,
ActiveMQDestination destination) |
protected boolean |
SelectorAwareVirtualTopicInterceptor.shouldDispatch(Broker broker,
Message message,
Destination dest)
Respect the selectors of the subscriptions to ensure only matched messages are dispatched to
the virtual queues, hence there is no build up of unmatched messages on these destinations
|
protected boolean |
VirtualTopicInterceptor.shouldDispatch(Broker broker,
Message message,
Destination dest) |
Modifier and Type | Class and Description |
---|---|
class |
SchedulerBroker |
Constructor and Description |
---|
SchedulerBroker(BrokerService brokerService,
Broker next,
JobSchedulerStore store) |
Modifier and Type | Class and Description |
---|---|
class |
DestinationPathSeparatorBroker |
class |
DestinationsPlugin
A simple plugin that can be used to export/import runtime destinations.
|
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 |
RedeliveryPlugin
Replace regular DLQ handling with redelivery via a resend to the original destination
after a delay
A destination matching RedeliveryPolicy controls the quantity and delay for re-sends
If there is no matching policy or an existing policy limit is exceeded by default
regular DLQ processing resumes.
|
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 | Method and Description |
---|---|
Broker |
RedeliveryPlugin.installPlugin(Broker broker) |
Modifier and Type | Method and Description |
---|---|
Broker |
RedeliveryPlugin.installPlugin(Broker broker) |
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 | Method and Description |
---|---|
static Transport |
NetworkBridgeFactory.createLocalTransport(Broker broker) |
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 |
DiscardingDLQBrokerPlugin.installPlugin(Broker broker)
Installs the plugin into the intercepter chain of the broker, returning the new
intercepted broker to use.
|
Broker |
ForcePersistencyModeBrokerPlugin.installPlugin(Broker broker) |
Broker |
StatisticsBrokerPlugin.installPlugin(Broker broker) |
Broker |
SubQueueSelectorCacheBrokerPlugin.installPlugin(Broker broker) |
Modifier and Type | Method and Description |
---|---|
Broker |
DiscardingDLQBrokerPlugin.installPlugin(Broker broker)
Installs the plugin into the intercepter chain of the broker, returning the new
intercepted broker to use.
|
Broker |
ForcePersistencyModeBrokerPlugin.installPlugin(Broker broker) |
Broker |
StatisticsBrokerPlugin.installPlugin(Broker broker) |
Broker |
SubQueueSelectorCacheBrokerPlugin.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 |
AbstractAuthenticationBroker |
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 |
SimpleAuthenticationPlugin.installPlugin(Broker parent) |
Broker |
JaasAuthenticationPlugin.installPlugin(Broker broker) |
Broker |
JaasCertificateAuthenticationPlugin.installPlugin(Broker broker) |
Modifier and Type | Method and Description |
---|---|
void |
AuthorizationDestinationInterceptor.create(Broker broker,
ConnectionContext context,
ActiveMQDestination destination) |
Broker |
AuthorizationPlugin.installPlugin(Broker broker) |
Broker |
JaasDualAuthenticationPlugin.installPlugin(Broker broker) |
Broker |
SimpleAuthenticationPlugin.installPlugin(Broker parent) |
Broker |
JaasAuthenticationPlugin.installPlugin(Broker broker) |
Broker |
JaasCertificateAuthenticationPlugin.installPlugin(Broker broker) |
Constructor and Description |
---|
AbstractAuthenticationBroker(Broker next) |
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 | Class and Description |
---|---|
class |
SecurityFilter |
class |
ShiroPlugin |
Modifier and Type | Method and Description |
---|---|
Broker |
ShiroPlugin.installPlugin(Broker broker) |
Modifier and Type | Method and Description |
---|---|
Broker |
ShiroPlugin.installPlugin(Broker broker) |
Modifier and Type | Class and Description |
---|---|
class |
AuthenticationFilter
The
AuthenticationFilter enforces if authentication is required before allowing the broker filter chain
to continue. |
Modifier and Type | Class and Description |
---|---|
class |
AuthorizationFilter
The
AuthorizationFilter asserts that actions are allowed to execute first before they are actually
executed. |
Modifier and Type | Class and Description |
---|---|
class |
EnvironmentFilter
An abstract
BrokerFilter that makes the Shiro Environment available to subclasses. |
Modifier and Type | Class and Description |
---|---|
class |
SubjectFilter
The
SubjectFilter ensures a Shiro Subject representing the client's identity is associated with
every connection to the ActiveMQ Broker. |
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–2024 The Apache Software Foundation. All rights reserved.