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

All Implemented Interfaces:
    Broker

This broker filter handles the transaction related operations in the Broker interface.
Fields inherited from org.apache.activemq.broker.BrokerFilter:
next
Constructor:
 public TransactionBroker(Broker next,
    TransactionStore transactionStore) 
Method from org.apache.activemq.broker.TransactionBroker Summary:
acknowledge,   beginTransaction,   brokerServiceStarted,   commitTransaction,   forgetTransaction,   getPreparedTransactions,   getTransaction,   prepareTransaction,   removeConnection,   removeTransaction,   rollbackTransaction,   send,   start,   stop
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.TransactionBroker Detail:
 public  void acknowledge(ConsumerBrokerExchange consumerExchange,
    MessageAck ack) throws Exception 
 public  void beginTransaction(ConnectionContext context,
    TransactionId xid) throws Exception 
 public synchronized  void brokerServiceStarted() 
 public  void commitTransaction(ConnectionContext context,
    TransactionId xid,
    boolean onePhase) throws Exception 
 public  void forgetTransaction(ConnectionContext context,
    TransactionId xid) throws Exception 
 public TransactionId[] getPreparedTransactions(ConnectionContext context) throws Exception 
 public Transaction getTransaction(ConnectionContext context,
    TransactionId xid,
    boolean mightBePrepared) throws JMSException, XAException 
 public int prepareTransaction(ConnectionContext context,
    TransactionId xid) throws Exception 
 public  void removeConnection(ConnectionContext context,
    ConnectionInfo info,
    Throwable error) throws Exception 
 public  void removeTransaction(XATransactionId xid) 
 public  void rollbackTransaction(ConnectionContext context,
    TransactionId xid) throws Exception 
 public  void send(ProducerBrokerExchange producerExchange,
    Message message) throws Exception 
 public  void start() throws Exception 
    Recovers any prepared transactions.
 public  void stop() throws Exception