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



Copyright © 2005-2011 Apache Software Foundation. All Rights Reserved.