|
||||||||||
PREV NEXT | FRAMES NO FRAMES |
Packages that use Broker | |
---|---|
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.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.web | Web Connectors so that messages can be sent via HTTP POST or read via HTTP POST or GET as well as support for web streaming to we browser or JavaScript clients. |
Uses of Broker in org.apache.activemq.advisory |
---|
Classes in org.apache.activemq.advisory that implement Broker | |
---|---|
class |
AdvisoryBroker
This broker filter handles tracking the state of the broker for purposes of publishing advisory messages to advisory consumers. |
Constructors in org.apache.activemq.advisory with parameters of type Broker | |
---|---|
AdvisoryBroker(Broker next)
|
Uses of Broker in org.apache.activemq.broker |
---|
Classes in org.apache.activemq.broker that implement Broker | |
---|---|
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. |
Fields in org.apache.activemq.broker declared as Broker | |
---|---|
protected Broker |
TransportConnection.broker
|
protected Broker[] |
BrokerBroadcaster.listeners
|
protected Broker |
BrokerFilter.next
|
Fields in org.apache.activemq.broker with type parameters of type Broker | |
---|---|
protected AtomicReference<Broker> |
MutableBrokerFilter.next
|
Methods in org.apache.activemq.broker that return Broker | |
---|---|
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 |
ConnectionContext.getBroker()
|
Broker |
TransportConnector.getBroker()
|
Broker |
BrokerService.getBroker()
Returns the message broker |
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)
|
Methods in org.apache.activemq.broker that return types with arguments of type Broker | |
---|---|
protected List<Broker> |
BrokerBroadcaster.getListenersAsList()
|
Methods in org.apache.activemq.broker with parameters of type Broker | |
---|---|
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)
|
protected void |
BrokerService.startDestinationsInPersistenceStore(Broker broker)
Starts all destiantions in persistence store. |
Constructors in org.apache.activemq.broker with parameters of type Broker | |
---|---|
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)
|
Uses of Broker in org.apache.activemq.broker.cluster |
---|
Classes in org.apache.activemq.broker.cluster that implement Broker | |
---|---|
class |
ConnectionSplitBroker
Monitors for client connections that may fail to another broker - but this broker isn't aware they've gone. |
Constructors in org.apache.activemq.broker.cluster with parameters of type Broker | |
---|---|
ConnectionSplitBroker(Broker next)
|
Uses of Broker in org.apache.activemq.broker.ft |
---|
Classes in org.apache.activemq.broker.ft that implement Broker | |
---|---|
class |
MasterBroker
The Message Broker which passes messages to a slave |
Uses of Broker in org.apache.activemq.broker.jmx |
---|
Classes in org.apache.activemq.broker.jmx that implement Broker | |
---|---|
class |
ManagedRegionBroker
|
Methods in org.apache.activemq.broker.jmx that return Broker | |
---|---|
Broker |
ManagedRegionBroker.getContextBroker()
|
Methods in org.apache.activemq.broker.jmx with parameters of type Broker | |
---|---|
protected static ConnectionContext |
BrokerView.createAdminConnectionContext(Broker broker)
Factory method to create the new administration connection context object. |
static ConnectionContext |
BrokerView.getConnectionContext(Broker broker)
Returns the broker's administration connection context used for configuring the broker at startup |
void |
ManagedRegionBroker.setContextBroker(Broker contextBroker)
|
Constructors in org.apache.activemq.broker.jmx with parameters of type Broker | |
---|---|
ManagedTransportConnection(TransportConnector connector,
Transport transport,
Broker broker,
TaskRunnerFactory factory,
ManagementContext context,
ObjectName connectorName)
|
Uses of Broker in org.apache.activemq.broker.region |
---|
Classes in org.apache.activemq.broker.region that implement Broker | |
---|---|
class |
RegionBroker
Routes Broker operations to the correct messaging regions for processing. |
Fields in org.apache.activemq.broker.region declared as Broker | |
---|---|
protected Broker |
BaseDestination.broker
|
protected Broker |
AbstractSubscription.broker
|
protected Broker |
BaseDestination.regionBroker
|
Methods in org.apache.activemq.broker.region that return Broker | |
---|---|
Broker |
RegionBroker.getAdaptor(Class type)
|
Broker |
RegionBroker.getRoot()
|
Constructors in org.apache.activemq.broker.region with parameters of type Broker | |
---|---|
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)
|
Uses of Broker in org.apache.activemq.broker.region.cursors |
---|
Fields in org.apache.activemq.broker.region.cursors declared as Broker | |
---|---|
protected Broker |
FilePendingMessageCursor.broker
|
Constructors in org.apache.activemq.broker.region.cursors with parameters of type Broker | |
---|---|
FilePendingMessageCursor(Broker broker,
String name)
|
|
StoreDurableSubscriberCursor(Broker broker,
String clientId,
String subscriberName,
int maxBatchSize,
Subscription subscription)
|
|
StoreQueueCursor(Broker broker,
Queue queue)
Construct |
Uses of Broker in org.apache.activemq.broker.region.policy |
---|
Methods in org.apache.activemq.broker.region.policy with parameters of type Broker | |
---|---|
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)
|
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)
Retrieve the configured pending message storage cursor; |
PendingMessageCursor |
FilePendingSubscriberMessageStoragePolicy.getSubscriberPendingMessageCursor(Broker broker,
String name,
int maxBatchSize)
|
PendingMessageCursor |
VMPendingSubscriberMessageStoragePolicy.getSubscriberPendingMessageCursor(Broker broker,
String name,
int maxBatchSize)
|
PendingMessageCursor |
PendingDurableSubscriberMessageStoragePolicy.getSubscriberPendingMessageCursor(Broker broker,
String clientId,
String name,
int maxBatchSize,
Subscription sub)
Retrieve the configured pending message storage cursor; |
PendingMessageCursor |
VMPendingDurableSubscriberMessageStoragePolicy.getSubscriberPendingMessageCursor(Broker broker,
String clientId,
String name,
int maxBatchSize,
Subscription sub)
Retrieve the configured pending message storage cursor; |
PendingMessageCursor |
FilePendingDurableSubscriberMessageStoragePolicy.getSubscriberPendingMessageCursor(Broker broker,
String clientId,
String name,
int maxBatchSize,
Subscription sub)
Retrieve the configured pending message storage cursor; |
PendingMessageCursor |
StorePendingDurableSubscriberMessageStoragePolicy.getSubscriberPendingMessageCursor(Broker broker,
String clientId,
String name,
int maxBatchSize,
Subscription sub)
Retrieve the configured pending message storage cursor; |
Uses of Broker in org.apache.activemq.broker.util |
---|
Classes in org.apache.activemq.broker.util that implement Broker | |
---|---|
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. |
Uses of Broker in org.apache.activemq.broker.view |
---|
Classes in org.apache.activemq.broker.view that implement Broker | |
---|---|
class |
ConnectionDotFileInterceptor
|
class |
DestinationDotFileInterceptor
|
class |
DotFileInterceptorSupport
Useful base class |
Methods in org.apache.activemq.broker.view that return Broker | |
---|---|
Broker |
ConnectionDotFilePlugin.installPlugin(Broker broker)
|
Broker |
DestinationDotFilePlugin.installPlugin(Broker broker)
|
Methods in org.apache.activemq.broker.view with parameters of type Broker | |
---|---|
Broker |
ConnectionDotFilePlugin.installPlugin(Broker broker)
|
Broker |
DestinationDotFilePlugin.installPlugin(Broker broker)
|
Constructors in org.apache.activemq.broker.view with parameters of type Broker | |
---|---|
ConnectionDotFileInterceptor(Broker next,
String file,
boolean redrawOnRemove)
|
|
DestinationDotFileInterceptor(Broker next,
String file)
|
|
DotFileInterceptorSupport(Broker next,
String file)
|
Uses of Broker in org.apache.activemq.plugin |
---|
Classes in org.apache.activemq.plugin that implement Broker | |
---|---|
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 |
Methods in org.apache.activemq.plugin that return Broker | |
---|---|
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 |
ForcePersistencyModeBrokerPlugin.installPlugin(Broker broker)
|
Methods in org.apache.activemq.plugin with parameters of type Broker | |
---|---|
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 |
ForcePersistencyModeBrokerPlugin.installPlugin(Broker broker)
|
Constructors in org.apache.activemq.plugin with parameters of type Broker | |
---|---|
DiscardingDLQBroker(Broker next)
|
|
ForcePersistencyModeBroker(Broker next)
Constructor |
|
StatisticsBroker(Broker next)
Constructor |
Uses of Broker in org.apache.activemq.security |
---|
Classes in org.apache.activemq.security that implement Broker | |
---|---|
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 |
SimpleAuthenticationBroker
Handles authenticating a users against a simple user name/password map. |
Methods in org.apache.activemq.security that return Broker | |
---|---|
Broker |
AuthorizationPlugin.installPlugin(Broker broker)
|
Broker |
SimpleAuthenticationPlugin.installPlugin(Broker broker)
|
Broker |
JaasAuthenticationPlugin.installPlugin(Broker broker)
|
Broker |
JaasCertificateAuthenticationPlugin.installPlugin(Broker broker)
|
Methods in org.apache.activemq.security with parameters of type Broker | |
---|---|
Broker |
AuthorizationPlugin.installPlugin(Broker broker)
|
Broker |
SimpleAuthenticationPlugin.installPlugin(Broker broker)
|
Broker |
JaasAuthenticationPlugin.installPlugin(Broker broker)
|
Broker |
JaasCertificateAuthenticationPlugin.installPlugin(Broker broker)
|
Constructors in org.apache.activemq.security with parameters of type Broker | |
---|---|
AuthorizationBroker(Broker next,
AuthorizationMap authorizationMap)
|
|
JaasAuthenticationBroker(Broker next,
String jassConfiguration)
|
|
JaasCertificateAuthenticationBroker(Broker next,
String jaasConfiguration)
Simple constructor. |
|
SimpleAuthenticationBroker(Broker next,
Map userPasswords,
Map userGroups)
|
Uses of Broker in org.apache.activemq.web |
---|
Methods in org.apache.activemq.web that return Broker | |
---|---|
Broker |
LocalBrokerFacade.getBroker()
|
|
||||||||||
PREV NEXT | FRAMES NO FRAMES |