org.apache.activemq.broker.ft
Class MasterBroker

java.lang.Object
  org.apache.activemq.broker.MutableBrokerFilter
      org.apache.activemq.broker.InsertableMutableBrokerFilter
          org.apache.activemq.broker.ft.MasterBroker

All Implemented Interfaces:

Broker, Region, Service

public class MasterBroker
extends InsertableMutableBrokerFilter

The Message Broker which passes messages to a slave

Version:

$Revision: 1.8 $

Constructor Summary

MasterBroker(MutableBrokerFilter parent, Transport slave)
Constructor

Method Summary

void	acknowledge(ConnectionContext context, MessageAck ack) Used to acknowledge the receipt of a message by a client.
void	addConnection(ConnectionContext context, ConnectionInfo info) A client is establishing a connection with the broker.
Subscription	addConsumer(ConnectionContext context, ConsumerInfo info) add a consumer
void	addProducer(ConnectionContext context, ProducerInfo info) Adds a producer.
void	addSession(ConnectionContext context, SessionInfo info) Adds a session.
void	beginTransaction(ConnectionContext context, TransactionId xid) begin a transaction
void	commitTransaction(ConnectionContext context, TransactionId xid, boolean onePhase) Commits a transaction.
void	forgetTransaction(ConnectionContext context, TransactionId xid) Forgets a transaction.
boolean	isFaultTolerantConfiguration()
int	prepareTransaction(ConnectionContext context, TransactionId xid) Prepares a transaction.
void	processDispatch(MessageDispatch messageDispatch) Notifiy the Broker that a dispatch has happened
void	removeConnection(ConnectionContext context, ConnectionInfo info, java.lang.Throwable error) A client is disconnecting from the broker.
void	removeProducer(ConnectionContext context, ProducerInfo info) Removes a producer.
void	removeSession(ConnectionContext context, SessionInfo info) Removes a session.
void	removeSubscription(ConnectionContext context, RemoveSubscriptionInfo info) remove a subscription
void	rollbackTransaction(ConnectionContext context, TransactionId xid) Rollsback a transaction.
void	send(ConnectionContext context, Message message) Send a message to the broker to using the specified destination.
protected void	sendAsyncToSlave(Command command)
protected void	sendSyncToSlave(Command command)
protected void	sendToSlave(Message message)
protected void	sendToSlave(MessageAck ack)
void	startProcessing() start processing this broker
void	stop() stop the broker
void	stopProcessing() stop processing this broker

Methods inherited from class org.apache.activemq.broker.InsertableMutableBrokerFilter

remove

Methods inherited from class org.apache.activemq.broker.MutableBrokerFilter

addBroker, addDestination, addDestinationInfo, gc, getAdaptor, getAdminConnectionContext, getBrokerId, getBrokerName, getClients, getDestinationMap, getDestinations, getDestinations, getDurableDestinations, getNext, getPeerBrokerInfos, getPendingDurableSubscriberPolicy, getPreparedTransactions, getTempDataStore, isSlaveBroker, isStopped, messagePull, processDispatchNotification, removeBroker, removeConsumer, removeDestination, removeDestinationInfo, setAdminConnectionContext, setNext, setPendingDurableSubscriberPolicy, start

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

MasterBroker

public MasterBroker(MutableBrokerFilter parent,
                    Transport slave)

Constructor

Parameters:

parent -

slave -

Method Detail

startProcessing

public void startProcessing()

start processing this broker

stop

public void stop()
          throws java.lang.Exception

stop the broker

Specified by:

stop in interface Service

Overrides:

stop in class MutableBrokerFilter

Throws:

java.lang.Exception

stopProcessing

public void stopProcessing()

stop processing this broker

addConnection

public void addConnection(ConnectionContext context,
                          ConnectionInfo info)
                   throws java.lang.Exception

A client is establishing a connection with the broker.

Specified by:

addConnection in interface Broker

Overrides:

addConnection in class MutableBrokerFilter

Parameters:

context -

info -

Throws:

java.lang.Exception

removeConnection

public void removeConnection(ConnectionContext context,
                             ConnectionInfo info,
                             java.lang.Throwable error)
                      throws java.lang.Exception

A client is disconnecting from the broker.

Specified by:

removeConnection in interface Broker

Overrides:

removeConnection in class MutableBrokerFilter

Parameters:

context - the environment the operation is being executed under.

info -

error - null if the client requested the disconnect or the error that caused the client to disconnect.

Throws:

java.lang.Exception

addSession

public void addSession(ConnectionContext context,
                       SessionInfo info)
                throws java.lang.Exception

Adds a session.

Specified by:

addSession in interface Broker

Overrides:

addSession in class MutableBrokerFilter

Parameters:

context -

info -

Throws:

java.lang.Exception

removeSession

public void removeSession(ConnectionContext context,
                          SessionInfo info)
                   throws java.lang.Exception

Removes a session.

Specified by:

removeSession in interface Broker

Overrides:

removeSession in class MutableBrokerFilter

Parameters:

context -

info -

Throws:

java.lang.Exception

addProducer

public void addProducer(ConnectionContext context,
                        ProducerInfo info)
                 throws java.lang.Exception

Adds a producer.

Specified by:

addProducer in interface Broker

Overrides:

addProducer in class MutableBrokerFilter

Parameters:

context - the enviorment the operation is being executed under.

info -

Throws:

java.lang.Exception

removeProducer

public void removeProducer(ConnectionContext context,
                           ProducerInfo info)
                    throws java.lang.Exception

Removes a producer.

Specified by:

removeProducer in interface Broker

Overrides:

removeProducer in class MutableBrokerFilter

Parameters:

context - the enviorment the operation is being executed under.

info -

Throws:

java.lang.Exception

addConsumer

public Subscription addConsumer(ConnectionContext context,
                                ConsumerInfo info)
                         throws java.lang.Exception

add a consumer

Specified by:

addConsumer in interface Region

Overrides:

addConsumer in class MutableBrokerFilter

Parameters:

context -

info -

Returns:

the assocated subscription

Throws:

java.lang.Exception

removeSubscription

public void removeSubscription(ConnectionContext context,
                               RemoveSubscriptionInfo info)
                        throws java.lang.Exception

remove a subscription

Specified by:

removeSubscription in interface Region

Overrides:

removeSubscription in class MutableBrokerFilter

Parameters:

context -

info -

Throws:

java.lang.Exception

beginTransaction

public void beginTransaction(ConnectionContext context,
                             TransactionId xid)
                      throws java.lang.Exception

begin a transaction

Specified by:

beginTransaction in interface Broker

Overrides:

beginTransaction in class MutableBrokerFilter

Parameters:

context -

xid -

Throws:

java.lang.Exception

prepareTransaction

public int prepareTransaction(ConnectionContext context,
                              TransactionId xid)
                       throws java.lang.Exception

Prepares a transaction. Only valid for xa transactions.

Specified by:

prepareTransaction in interface Broker

Overrides:

prepareTransaction in class MutableBrokerFilter

Parameters:

context -

xid -

Returns:

the state

Throws:

java.lang.Exception

rollbackTransaction

public void rollbackTransaction(ConnectionContext context,
                                TransactionId xid)
                         throws java.lang.Exception

Rollsback a transaction.

Specified by:

rollbackTransaction in interface Broker

Overrides:

rollbackTransaction in class MutableBrokerFilter

Parameters:

context -

xid -

Throws:

java.lang.Exception

commitTransaction

public void commitTransaction(ConnectionContext context,
                              TransactionId xid,
                              boolean onePhase)
                       throws java.lang.Exception

Commits a transaction.

Specified by:

commitTransaction in interface Broker

Overrides:

commitTransaction in class MutableBrokerFilter

Parameters:

context -

xid -

onePhase -

Throws:

java.lang.Exception

forgetTransaction

public void forgetTransaction(ConnectionContext context,
                              TransactionId xid)
                       throws java.lang.Exception

Forgets a transaction.

Specified by:

forgetTransaction in interface Broker

Overrides:

forgetTransaction in class MutableBrokerFilter

Parameters:

context -

xid -

Throws:

java.lang.Exception

processDispatch

public void processDispatch(MessageDispatch messageDispatch)

Notifiy the Broker that a dispatch has happened

Specified by:

processDispatch in interface Broker

Overrides:

processDispatch in class MutableBrokerFilter

Parameters:

messageDispatch -

send

public void send(ConnectionContext context,
                 Message message)
          throws java.lang.Exception

Description copied from interface: Region

Send a message to the broker to using the specified destination. The destination specified in the message does not need to match the destination the message is sent to. This is handy in case the message is being sent to a dead letter destination.

Specified by:

send in interface Region

Overrides:

send in class MutableBrokerFilter

Parameters:

context -

message -

Throws:

java.lang.Exception

acknowledge

public void acknowledge(ConnectionContext context,
                        MessageAck ack)
                 throws java.lang.Exception

Description copied from interface: Region

Used to acknowledge the receipt of a message by a client.

Specified by:

acknowledge in interface Region

Overrides:

acknowledge in class MutableBrokerFilter

Parameters:

context -

ack -

Throws:

java.lang.Exception

isFaultTolerantConfiguration

public boolean isFaultTolerantConfiguration()

Specified by:

isFaultTolerantConfiguration in interface Broker

Overrides:

isFaultTolerantConfiguration in class MutableBrokerFilter

Returns:

true if fault tolerant

sendToSlave

protected void sendToSlave(Message message)

sendToSlave

protected void sendToSlave(MessageAck ack)

sendAsyncToSlave

protected void sendAsyncToSlave(Command command)

sendSyncToSlave

protected void sendSyncToSlave(Command command)