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

All Implemented Interfaces:
    Broker

Monitors for client connections that may fail to another broker - but this broker isn't aware they've gone. Can occur with network glitches or client error
Fields inherited from org.apache.activemq.broker.BrokerFilter:
next
Constructor:
 public ConnectionSplitBroker(Broker next) 
Method from org.apache.activemq.broker.cluster.ConnectionSplitBroker Summary:
addConsumer,   removeConsumer
Methods from org.apache.activemq.broker.BrokerFilter:
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.cluster.ConnectionSplitBroker Detail:
 public Subscription addConsumer(ConnectionContext context,
    ConsumerInfo info) throws Exception 
 public  void removeConsumer(ConnectionContext context,
    ConsumerInfo info) throws Exception