Uses of Interface
org.apache.activemq.broker.Broker

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  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 MutableBrokerFilter.getAdaptor(Class type)
           
 Broker ErrorBroker.getAdaptor(Class type)
           
 Broker EmptyBroker.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 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 ErrorBroker.getRoot()
           
 Broker EmptyBroker.getRoot()
           
 Broker BrokerFilter.getRoot()
           
 Broker Broker.getRoot()
          Ensure we get the Broker at the top of the Stack
 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.
 

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 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)
           
 

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, TaskRunnerFactory stopTaskRunnerFactory)
           
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, TaskRunnerFactory stopFactory, 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()
           
 

Methods in org.apache.activemq.broker.region with parameters of type Broker
 void DestinationInterceptor.create(Broker broker, ConnectionContext context, ActiveMQDestination destination)
           
 void CompositeDestinationInterceptor.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, String name, boolean prioritizedMessages)
           
StoreDurableSubscriberCursor(Broker broker, String clientId, 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 VMPendingQueueMessageStoragePolicy.getQueuePendingMessageCursor(Broker broker, Queue queue)
           
 PendingMessageCursor StorePendingQueueMessageStoragePolicy.getQueuePendingMessageCursor(Broker broker, Queue queue)
           
 PendingMessageCursor PendingQueueMessageStoragePolicy.getQueuePendingMessageCursor(Broker broker, Queue queue)
          Retrieve the configured pending message storage cursor;
 PendingMessageCursor FilePendingQueueMessageStoragePolicy.getQueuePendingMessageCursor(Broker broker, Queue queue)
           
 PendingMessageCursor VMPendingSubscriberMessageStoragePolicy.getSubscriberPendingMessageCursor(Broker broker, String name, int maxBatchSize, Subscription subs)
           
 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 VMPendingDurableSubscriberMessageStoragePolicy.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 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;
 void TimedSubscriptionRecoveryPolicy.setBroker(Broker broker)
           
 void SubscriptionRecoveryPolicy.setBroker(Broker broker)
           
 void QueryBasedSubscriptionRecoveryPolicy.setBroker(Broker broker)
           
 void NoSubscriptionRecoveryPolicy.setBroker(Broker broker)
           
 void LastImageSubscriptionRecoveryPolicy.setBroker(Broker broker)
           
 void FixedSizedSubscriptionRecoveryPolicy.setBroker(Broker broker)
           
 void FixedCountSubscriptionRecoveryPolicy.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 VirtualTopic.create(Broker broker, ConnectionContext context, ActiveMQDestination destination)
           
 void VirtualDestinationInterceptor.create(Broker broker, ConnectionContext context, ActiveMQDestination destination)
           
 void MirroredQueue.create(Broker broker, ConnectionContext context, ActiveMQDestination destination)
           
 void CompositeDestination.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, 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 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.
 

Methods in org.apache.activemq.broker.util that return Broker
 Broker RedeliveryPlugin.installPlugin(Broker broker)
           
 

Methods in org.apache.activemq.broker.util with parameters of type Broker
 Broker RedeliveryPlugin.installPlugin(Broker broker)
           
 

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, 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
 class SubQueueSelectorCacheBroker
          A plugin which allows the caching of the selector from a subscription queue.
 

Methods in org.apache.activemq.plugin that return Broker
 Broker SubQueueSelectorCacheBrokerPlugin.installPlugin(Broker broker)
           
 Broker StatisticsBrokerPlugin.installPlugin(Broker broker)
           
 Broker ForcePersistencyModeBrokerPlugin.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.
 

Methods in org.apache.activemq.plugin with parameters of type Broker
 Broker SubQueueSelectorCacheBrokerPlugin.installPlugin(Broker broker)
           
 Broker StatisticsBrokerPlugin.installPlugin(Broker broker)
           
 Broker ForcePersistencyModeBrokerPlugin.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.
 

Constructors in org.apache.activemq.plugin with parameters of type Broker
DiscardingDLQBroker(Broker next)
           
ForcePersistencyModeBroker(Broker next)
          Constructor
StatisticsBroker(Broker next)
          Constructor
SubQueueSelectorCacheBroker(Broker next, File persistFile)
          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 SimpleAuthenticationPlugin.installPlugin(Broker parent)
           
 Broker JaasDualAuthenticationPlugin.installPlugin(Broker broker)
           
 Broker JaasCertificateAuthenticationPlugin.installPlugin(Broker broker)
           
 Broker JaasAuthenticationPlugin.installPlugin(Broker broker)
           
 Broker AuthorizationPlugin.installPlugin(Broker broker)
           
 

Methods in org.apache.activemq.security with parameters of type Broker
 Broker SimpleAuthenticationPlugin.installPlugin(Broker parent)
           
 Broker JaasDualAuthenticationPlugin.installPlugin(Broker broker)
           
 Broker JaasCertificateAuthenticationPlugin.installPlugin(Broker broker)
           
 Broker JaasAuthenticationPlugin.installPlugin(Broker broker)
           
 Broker AuthorizationPlugin.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.
JaasDualAuthenticationBroker(Broker next, String jaasConfiguration, String jaasSslConfiguration)
          Simple constructor.
SimpleAuthenticationBroker(Broker next, Map<String,String> userPasswords, Map<String,Set<Principal>> 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
 



Copyright © 2005-2012 The Apache Software Foundation. All Rights Reserved.