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.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.
|
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.
|
Modifier and Type | Interface and Description |
---|---|
interface |
Broker
The Message Broker which routes messages, maintains subscriptions and
connections, acknowledges messages and handles transactions.
|
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 | Method and Description |
---|---|
Region |
ProducerBrokerExchange.getRegion() |
Region |
ConsumerBrokerExchange.getRegion() |
Modifier and Type | Method and Description |
---|---|
void |
ProducerBrokerExchange.setRegion(Region region) |
void |
ConsumerBrokerExchange.setRegion(Region region) |
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.
|
Modifier and Type | Class and Description |
---|---|
class |
MasterBroker
The Message Broker which passes messages to a slave
|
Modifier and Type | Class and Description |
---|---|
class |
ManagedQueueRegion |
class |
ManagedRegionBroker |
class |
ManagedTempQueueRegion |
class |
ManagedTempTopicRegion |
class |
ManagedTopicRegion |
Modifier and Type | Method and Description |
---|---|
protected Region |
ManagedRegionBroker.createQueueRegion(SystemUsage memoryManager,
TaskRunnerFactory taskRunnerFactory,
DestinationFactory destinationFactory) |
protected Region |
ManagedRegionBroker.createTempQueueRegion(SystemUsage memoryManager,
TaskRunnerFactory taskRunnerFactory,
DestinationFactory destinationFactory) |
protected Region |
ManagedRegionBroker.createTempTopicRegion(SystemUsage memoryManager,
TaskRunnerFactory taskRunnerFactory,
DestinationFactory destinationFactory) |
protected Region |
ManagedRegionBroker.createTopicRegion(SystemUsage memoryManager,
TaskRunnerFactory taskRunnerFactory,
DestinationFactory destinationFactory) |
Modifier and Type | Class and Description |
---|---|
class |
AbstractRegion |
class |
AbstractTempRegion |
class |
QueueRegion |
class |
RegionBroker
Routes Broker operations to the correct messaging regions for processing.
|
class |
TempQueueRegion |
class |
TempTopicRegion |
class |
TopicRegion |
Modifier and Type | Method and Description |
---|---|
protected Region |
RegionBroker.createQueueRegion(SystemUsage memoryManager,
TaskRunnerFactory taskRunnerFactory,
DestinationFactory destinationFactory) |
protected Region |
RegionBroker.createTempQueueRegion(SystemUsage memoryManager,
TaskRunnerFactory taskRunnerFactory,
DestinationFactory destinationFactory) |
protected Region |
RegionBroker.createTempTopicRegion(SystemUsage memoryManager,
TaskRunnerFactory taskRunnerFactory,
DestinationFactory destinationFactory) |
protected Region |
RegionBroker.createTopicRegion(SystemUsage memoryManager,
TaskRunnerFactory taskRunnerFactory,
DestinationFactory destinationFactory) |
Region |
RegionBroker.getQueueRegion() |
Region |
RegionBroker.getTempQueueRegion() |
Region |
RegionBroker.getTempTopicRegion() |
Region |
RegionBroker.getTopicRegion() |
Modifier and Type | Class and Description |
---|---|
class |
SchedulerBroker |
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 | 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 | 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.
|
Copyright © 2005–2016. All rights reserved.