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

All Implemented Interfaces:
    Broker

The Message Broker which passes messages to a slave
Fields inherited from org.apache.activemq.broker.InsertableMutableBrokerFilter:
parent
Fields inherited from org.apache.activemq.broker.MutableBrokerFilter:
next
Constructor:
 public MasterBroker(MutableBrokerFilter parent,
    Transport transport) 
    Constructor
    Parameters:
    parent -
    transport -
Method from org.apache.activemq.broker.ft.MasterBroker Summary:
acknowledge,   addConnection,   addConsumer,   addDestinationInfo,   addProducer,   addSession,   beginTransaction,   commitTransaction,   forgetTransaction,   isFaultTolerantConfiguration,   preProcessDispatch,   prepareTransaction,   removeConnection,   removeConsumer,   removeDestinationInfo,   removeProducer,   removeSession,   removeSubscription,   rollbackTransaction,   send,   sendAsyncToSlave,   sendSyncToSlave,   sendToSlave,   sendToSlave,   startProcessing,   stop,   stopProcessing
Methods from org.apache.activemq.broker.InsertableMutableBrokerFilter:
remove
Methods from org.apache.activemq.broker.MutableBrokerFilter:
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,   getNext,   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,   setNext,   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.ft.MasterBroker Detail:
 public  void acknowledge(ConsumerBrokerExchange consumerExchange,
    MessageAck ack) throws Exception 
 public  void addConnection(ConnectionContext context,
    ConnectionInfo info) throws Exception 
    A client is establishing a connection with the broker.
 public Subscription addConsumer(ConnectionContext context,
    ConsumerInfo info) throws Exception 
    add a consumer
 public  void addDestinationInfo(ConnectionContext context,
    DestinationInfo info) throws Exception 
 public  void addProducer(ConnectionContext context,
    ProducerInfo info) throws Exception 
    Adds a producer.
 public  void addSession(ConnectionContext context,
    SessionInfo info) throws Exception 
    Adds a session.
 public  void beginTransaction(ConnectionContext context,
    TransactionId xid) throws Exception 
    begin a transaction
 public  void commitTransaction(ConnectionContext context,
    TransactionId xid,
    boolean onePhase) throws Exception 
    Commits a transaction.
 public  void forgetTransaction(ConnectionContext context,
    TransactionId xid) throws Exception 
    Forgets a transaction.
 public boolean isFaultTolerantConfiguration() 
 public  void preProcessDispatch(MessageDispatch messageDispatch) 
    Notifiy the Broker that a dispatch will happen Do in 'pre' so that slave will avoid getting ack before dispatch similar logic to send() below.
 public int prepareTransaction(ConnectionContext context,
    TransactionId xid) throws Exception 
    Prepares a transaction. Only valid for xa transactions.
 public  void removeConnection(ConnectionContext context,
    ConnectionInfo info,
    Throwable error) throws Exception 
    A client is disconnecting from the broker.
 public  void removeConsumer(ConnectionContext context,
    ConsumerInfo info) throws Exception 
 public  void removeDestinationInfo(ConnectionContext context,
    DestinationInfo info) throws Exception 
 public  void removeProducer(ConnectionContext context,
    ProducerInfo info) throws Exception 
    Removes a producer.
 public  void removeSession(ConnectionContext context,
    SessionInfo info) throws Exception 
    Removes a session.
 public  void removeSubscription(ConnectionContext context,
    RemoveSubscriptionInfo info) throws Exception 
    remove a subscription
 public  void rollbackTransaction(ConnectionContext context,
    TransactionId xid) throws Exception 
    Rollsback a transaction.
 public  void send(ProducerBrokerExchange producerExchange,
    Message message) throws Exception 
 protected  void sendAsyncToSlave(Command command) 
 protected  void sendSyncToSlave(Command command) 
 protected  void sendToSlave(Message message) 
 protected  void sendToSlave(MessageAck ack) 
 public  void startProcessing() 
    start processing this broker
 public  void stop() throws Exception 
    stop the broker
 public  void stopProcessing() 
    stop processing this broker