|
||||||||||
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.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 |
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 java.util.concurrent.atomic.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(java.lang.Class type)
Get a Broker from the Broker Stack that is a particular class |
Broker |
EmptyBroker.getAdaptor(java.lang.Class type)
|
Broker |
MutableBrokerFilter.getAdaptor(java.lang.Class type)
|
Broker |
BrokerFilter.getAdaptor(java.lang.Class type)
|
Broker |
ErrorBroker.getAdaptor(java.lang.Class type)
|
Broker |
TransportConnector.getBroker()
|
Broker |
BrokerService.getBroker()
Returns the message broker |
Broker |
ConnectionContext.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)
|
Methods in org.apache.activemq.broker that return types with arguments of type Broker | |
---|---|
protected java.util.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 | |
---|---|
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,
javax.management.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(java.lang.Class type)
|
Broker |
RegionBroker.getRoot()
|
Methods in org.apache.activemq.broker.region with parameters of type Broker | |
---|---|
void |
CompositeDestinationInterceptor.create(Broker broker,
ConnectionContext context,
ActiveMQDestination destination)
|
void |
DestinationInterceptor.create(Broker broker,
ConnectionContext context,
ActiveMQDestination destination)
|
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
|
Methods in org.apache.activemq.broker.region.cursors with parameters of type Broker | |
---|---|
static boolean |
AbstractPendingMessageCursor.isPrioritizedMessageSubscriber(Broker broker,
Subscription sub)
|
Constructors in org.apache.activemq.broker.region.cursors with parameters of type Broker | |
---|---|
FilePendingMessageCursor(Broker broker,
java.lang.String name,
boolean prioritizedMessages)
|
|
StoreDurableSubscriberCursor(Broker broker,
java.lang.String clientId,
java.lang.String subscriberName,
int maxBatchSize,
DurableTopicSubscription 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.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 |
VMPendingSubscriberMessageStoragePolicy.getSubscriberPendingMessageCursor(Broker broker,
java.lang.String name,
int maxBatchSize,
Subscription subs)
|
PendingMessageCursor |
PendingSubscriberMessageStoragePolicy.getSubscriberPendingMessageCursor(Broker broker,
java.lang.String name,
int maxBatchSize,
Subscription subs)
Retrieve the configured pending message storage cursor; |
PendingMessageCursor |
FilePendingSubscriberMessageStoragePolicy.getSubscriberPendingMessageCursor(Broker broker,
java.lang.String name,
int maxBatchSize,
Subscription subs)
|
PendingMessageCursor |
VMPendingDurableSubscriberMessageStoragePolicy.getSubscriberPendingMessageCursor(Broker broker,
java.lang.String clientId,
java.lang.String name,
int maxBatchSize,
DurableTopicSubscription sub)
Retrieve the configured pending message storage cursor; |
PendingMessageCursor |
FilePendingDurableSubscriberMessageStoragePolicy.getSubscriberPendingMessageCursor(Broker broker,
java.lang.String clientId,
java.lang.String name,
int maxBatchSize,
DurableTopicSubscription sub)
Retrieve the configured pending message storage cursor; |
PendingMessageCursor |
PendingDurableSubscriberMessageStoragePolicy.getSubscriberPendingMessageCursor(Broker broker,
java.lang.String clientId,
java.lang.String name,
int maxBatchSize,
DurableTopicSubscription sub)
Retrieve the configured pending message storage cursor; |
PendingMessageCursor |
StorePendingDurableSubscriberMessageStoragePolicy.getSubscriberPendingMessageCursor(Broker broker,
java.lang.String clientId,
java.lang.String name,
int maxBatchSize,
DurableTopicSubscription sub)
Retrieve the configured pending message storage cursor; |
void |
TimedSubscriptionRecoveryPolicy.setBroker(Broker broker)
|
void |
NoSubscriptionRecoveryPolicy.setBroker(Broker broker)
|
void |
FixedSizedSubscriptionRecoveryPolicy.setBroker(Broker broker)
|
void |
LastImageSubscriptionRecoveryPolicy.setBroker(Broker broker)
|
void |
SubscriptionRecoveryPolicy.setBroker(Broker broker)
|
void |
FixedCountSubscriptionRecoveryPolicy.setBroker(Broker broker)
|
void |
QueryBasedSubscriptionRecoveryPolicy.setBroker(Broker broker)
|
void |
SlowConsumerStrategy.setBrokerService(Broker broker)
|
void |
AbortSlowConsumerStrategy.setBrokerService(Broker broker)
|
Uses of Broker in org.apache.activemq.broker.region.virtual |
---|
Methods in org.apache.activemq.broker.region.virtual with parameters of type Broker | |
---|---|
void |
VirtualDestinationInterceptor.create(Broker broker,
ConnectionContext context,
ActiveMQDestination destination)
|
void |
CompositeDestination.create(Broker broker,
ConnectionContext context,
ActiveMQDestination destination)
|
void |
MirroredQueue.create(Broker broker,
ConnectionContext context,
ActiveMQDestination destination)
|
void |
VirtualTopic.create(Broker broker,
ConnectionContext context,
ActiveMQDestination destination)
|
Uses of Broker in org.apache.activemq.broker.scheduler |
---|
Classes in org.apache.activemq.broker.scheduler that implement Broker | |
---|---|
class |
SchedulerBroker
|
Constructors in org.apache.activemq.broker.scheduler with parameters of type Broker | |
---|---|
SchedulerBroker(Broker next,
java.io.File directory)
|
Uses of Broker in org.apache.activemq.broker.util |
---|
Classes in org.apache.activemq.broker.util that implement Broker | |
---|---|
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. |
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 |
DestinationDotFilePlugin.installPlugin(Broker broker)
|
Broker |
ConnectionDotFilePlugin.installPlugin(Broker broker)
|
Methods in org.apache.activemq.broker.view with parameters of type Broker | |
---|---|
Broker |
DestinationDotFilePlugin.installPlugin(Broker broker)
|
Broker |
ConnectionDotFilePlugin.installPlugin(Broker broker)
|
Constructors in org.apache.activemq.broker.view with parameters of type Broker | |
---|---|
ConnectionDotFileInterceptor(Broker next,
java.lang.String file,
boolean redrawOnRemove)
|
|
DestinationDotFileInterceptor(Broker next,
java.lang.String file)
|
|
DotFileInterceptorSupport(Broker next,
java.lang.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 |
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. |
Methods in org.apache.activemq.security that return Broker | |
---|---|
Broker |
JaasAuthenticationPlugin.installPlugin(Broker broker)
|
Broker |
JaasCertificateAuthenticationPlugin.installPlugin(Broker broker)
|
Broker |
AuthorizationPlugin.installPlugin(Broker broker)
|
Broker |
SimpleAuthenticationPlugin.installPlugin(Broker parent)
|
Broker |
JaasDualAuthenticationPlugin.installPlugin(Broker broker)
|
Methods in org.apache.activemq.security with parameters of type Broker | |
---|---|
Broker |
JaasAuthenticationPlugin.installPlugin(Broker broker)
|
Broker |
JaasCertificateAuthenticationPlugin.installPlugin(Broker broker)
|
Broker |
AuthorizationPlugin.installPlugin(Broker broker)
|
Broker |
SimpleAuthenticationPlugin.installPlugin(Broker parent)
|
Broker |
JaasDualAuthenticationPlugin.installPlugin(Broker broker)
|
Constructors in org.apache.activemq.security with parameters of type Broker | |
---|---|
AuthorizationBroker(Broker next,
AuthorizationMap authorizationMap)
|
|
JaasAuthenticationBroker(Broker next,
java.lang.String jassConfiguration)
|
|
JaasCertificateAuthenticationBroker(Broker next,
java.lang.String jaasConfiguration)
Simple constructor. |
|
JaasDualAuthenticationBroker(Broker next,
java.lang.String jaasConfiguration,
java.lang.String jaasSslConfiguration)
Simple constructor. |
|
SimpleAuthenticationBroker(Broker next,
java.util.Map userPasswords,
java.util.Map userGroups)
|
Uses of Broker in org.apache.activemq.util |
---|
Methods in org.apache.activemq.util with parameters of type Broker | |
---|---|
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 |
|
||||||||||
PREV NEXT | FRAMES NO FRAMES |