Home » activemq-parent-5.3.1-source-release » org.apache » activemq » broker » [javadoc | source]
org.apache.activemq.broker
public class: BrokerFilter [javadoc | source]
java.lang.Object
   org.apache.activemq.broker.BrokerFilter

All Implemented Interfaces:
    Broker

Direct Known Subclasses:
    CompositeDestinationBroker, DiscardingDLQBroker, StatisticsBroker, JaasCertificateAuthenticationBroker, DotFileInterceptorSupport, SimpleAuthenticationBroker, AdvisoryBroker, TransactionBroker, DestinationDotFileInterceptor, AuthorizationBroker, ForcePersistencyModeBroker, ConnectionDotFileInterceptor, JaasAuthenticationBroker, BrokerBroadcaster, UserIDBroker, ConnectionSplitBroker

Allows you to intercept broker operation so that features such as security can be implemented as a pluggable filter.
Field Summary
protected final  Broker next     
Constructor:
 public BrokerFilter(Broker next) 
Method from org.apache.activemq.broker.BrokerFilter Summary:
acknowledge,   addBroker,   addConnection,   addConsumer,   addDestination,   addDestinationInfo,   addProducer,   addSession,   beginTransaction,   brokerServiceStarted,   commitTransaction,   fastProducer,   forgetTransaction,   gc,   getAdaptor,   getAdminConnectionContext,   getBrokerId,   getBrokerName,   getBrokerSequenceId,   getBrokerService,   getClients,   getDestinationMap,   getDestinations,   getDestinations,   getDurableDestinations,   getPeerBrokerInfos,   getPreparedTransactions,   getRoot,   getTempDataStore,   getVmConnectorURI,   isExpired,   isFaultTolerantConfiguration,   isFull,   isStopped,   messageConsumed,   messageDelivered,   messageDiscarded,   messageExpired,   messagePull,   nowMasterBroker,   postProcessDispatch,   preProcessDispatch,   prepareTransaction,   processDispatchNotification,   removeBroker,   removeConnection,   removeConsumer,   removeDestination,   removeDestinationInfo,   removeProducer,   removeSession,   removeSubscription,   rollbackTransaction,   send,   sendToDeadLetterQueue,   setAdminConnectionContext,   slowConsumer,   start,   stop
Methods from java.lang.Object:
clone,   equals,   finalize,   getClass,   hashCode,   notify,   notifyAll,   toString,   wait,   wait,   wait
Method from org.apache.activemq.broker.BrokerFilter Detail:
 public  void acknowledge(ConsumerBrokerExchange consumerExchange,
    MessageAck ack) throws Exception 
 public  void addBroker(Connection connection,
    BrokerInfo info) 
 public  void addConnection(ConnectionContext context,
    ConnectionInfo info) throws Exception 
 public Subscription addConsumer(ConnectionContext context,
    ConsumerInfo info) throws Exception 
 public Destination addDestination(ConnectionContext context,
    ActiveMQDestination destination) throws Exception 
 public  void addDestinationInfo(ConnectionContext context,
    DestinationInfo info) throws Exception 
 public  void addProducer(ConnectionContext context,
    ProducerInfo info) throws Exception 
 public  void addSession(ConnectionContext context,
    SessionInfo info) throws Exception 
 public  void beginTransaction(ConnectionContext context,
    TransactionId xid) throws Exception 
 public  void brokerServiceStarted() 
 public  void commitTransaction(ConnectionContext context,
    TransactionId xid,
    boolean onePhase) throws Exception 
 public  void fastProducer(ConnectionContext context,
    ProducerInfo producerInfo) 
 public  void forgetTransaction(ConnectionContext context,
    TransactionId transactionId) throws Exception 
 public  void gc() 
 public Broker getAdaptor(Class type) 
 public ConnectionContext getAdminConnectionContext() 
 public BrokerId getBrokerId() 
 public String getBrokerName() 
 public long getBrokerSequenceId() 
 public BrokerService getBrokerService() 
 public Connection[] getClients() throws Exception 
 public Map<ActiveMQDestination, Destination> getDestinationMap() 
 public ActiveMQDestination[] getDestinations() throws Exception 
 public Set<Destination> getDestinations(ActiveMQDestination destination) 
 public Set<ActiveMQDestination> getDurableDestinations() 
 public BrokerInfo[] getPeerBrokerInfos() 
 public TransactionId[] getPreparedTransactions(ConnectionContext context) throws Exception 
 public Broker getRoot() 
 public Store getTempDataStore() 
 public URI getVmConnectorURI() 
 public boolean isExpired(MessageReference messageReference) 
 public boolean isFaultTolerantConfiguration() 
 public  void isFull(ConnectionContext context,
    Destination destination,
    Usage usage) 
 public boolean isStopped() 
 public  void messageConsumed(ConnectionContext context,
    MessageReference messageReference) 
 public  void messageDelivered(ConnectionContext context,
    MessageReference messageReference) 
 public  void messageDiscarded(ConnectionContext context,
    MessageReference messageReference) 
 public  void messageExpired(ConnectionContext context,
    MessageReference message) 
 public Response messagePull(ConnectionContext context,
    MessagePull pull) throws Exception 
 public  void nowMasterBroker() 
 public  void postProcessDispatch(MessageDispatch messageDispatch) 
 public  void preProcessDispatch(MessageDispatch messageDispatch) 
 public int prepareTransaction(ConnectionContext context,
    TransactionId xid) throws Exception 
 public  void processDispatchNotification(MessageDispatchNotification messageDispatchNotification) throws Exception 
 public  void removeBroker(Connection connection,
    BrokerInfo info) 
 public  void removeConnection(ConnectionContext context,
    ConnectionInfo info,
    Throwable error) throws Exception 
 public  void removeConsumer(ConnectionContext context,
    ConsumerInfo info) throws Exception 
 public  void removeDestination(ConnectionContext context,
    ActiveMQDestination destination,
    long timeout) throws Exception 
 public  void removeDestinationInfo(ConnectionContext context,
    DestinationInfo info) throws Exception 
 public  void removeProducer(ConnectionContext context,
    ProducerInfo info) throws Exception 
 public  void removeSession(ConnectionContext context,
    SessionInfo info) throws Exception 
 public  void removeSubscription(ConnectionContext context,
    RemoveSubscriptionInfo info) throws Exception 
 public  void rollbackTransaction(ConnectionContext context,
    TransactionId xid) throws Exception 
 public  void send(ProducerBrokerExchange producerExchange,
    Message messageSend) throws Exception 
 public  void sendToDeadLetterQueue(ConnectionContext context,
    MessageReference messageReference) 
 public  void setAdminConnectionContext(ConnectionContext adminConnectionContext) 
 public  void slowConsumer(ConnectionContext context,
    Destination destination,
    Subscription subs) 
 public  void start() throws Exception 
 public  void stop() throws Exception