org.apache.activemq.camel.camelplugin

Class CamelRoutesBroker

java.lang.Object

org.apache.activemq.broker.BrokerFilter

org.apache.activemq.camel.camelplugin.CamelRoutesBroker

All Implemented Interfaces:

Broker, Region, Service

public class CamelRoutesBroker
extends BrokerFilter

A StatisticsBroker You can retrieve a Map Message for a Destination - or Broker containing statistics as key-value pairs The message must contain a replyTo Destination - else its ignored

Field Summary

Fields inherited from class org.apache.activemq.broker.BrokerFilter

next

Constructor Summary

Constructors

Constructor and Description
CamelRoutesBroker(Broker next)

Method Summary

Methods

Modifier and Type	Method and Description
void	acknowledge(ConsumerBrokerExchange consumerExchange, MessageAck ack) Used to acknowledge the receipt of a message by a client.
void	beginTransaction(ConnectionContext context, TransactionId xid) Starts a transaction.
void	commitTransaction(ConnectionContext context, TransactionId xid, boolean onePhase) Commits a transaction.
void	forgetTransaction(ConnectionContext context, TransactionId transactionId) Forgets a transaction.
int	getCheckPeriod()
String	getRoutesFile()
void	isFull(ConnectionContext context, Destination destination, Usage usage) Called when a Usage reaches a limit
void	messageConsumed(ConnectionContext context, MessageReference messageReference) called when message is consumed
void	messageDelivered(ConnectionContext context, MessageReference messageReference) Called when message is delivered to the broker
void	messageDiscarded(ConnectionContext context, Subscription sub, MessageReference messageReference) Called when a message is discarded - e.g.
Response	messagePull(ConnectionContext context, MessagePull pull) Allows a consumer to pull a message from a queue
void	nowMasterBroker() called when the broker becomes the master in a master/slave configuration
void	postProcessDispatch(MessageDispatch messageDispatch) Notify the Broker that a dispatch has happened
int	prepareTransaction(ConnectionContext context, TransactionId xid) Prepares a transaction.
void	preProcessDispatch(MessageDispatch messageDispatch) Notify the Broker that a dispatch is going to happen
void	processConsumerControl(ConsumerBrokerExchange consumerExchange, ConsumerControl control)
void	reapplyInterceptor()
void	rollbackTransaction(ConnectionContext context, TransactionId xid) Rollsback a transaction.
void	send(ProducerBrokerExchange producerExchange, Message message) Overide methods to pause the broker whilst camel routes are loaded
boolean	sendToDeadLetterQueue(ConnectionContext context, MessageReference messageReference, Subscription subscription, Throwable poisonCause) A message needs to go the a DLQ
void	setCheckPeriod(int checkPeriod)
void	setRoutesFile(String routesFile)
void	start()
void	stop()

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

addBroker, addConnection, addConsumer, addDestination, addDestinationInfo, addProducer, addSession, brokerServiceStarted, fastProducer, gc, getAdaptor, getAdminConnectionContext, getBrokerId, getBrokerName, getBrokerSequenceId, getBrokerService, getClients, getDestinationMap, getDestinationMap, getDestinations, getDestinations, getDurableDestinations, getExecutor, getPeerBrokerInfos, getPreparedTransactions, getRoot, getScheduler, getTempDataStore, getVmConnectorURI, isExpired, isFaultTolerantConfiguration, isStopped, messageExpired, networkBridgeStarted, networkBridgeStopped, processDispatchNotification, removeBroker, removeConnection, removeConsumer, removeDestination, removeDestinationInfo, removeProducer, removeSession, removeSubscription, setAdminConnectionContext, slowConsumer

Methods inherited from class java.lang.Object

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

Constructor Detail

CamelRoutesBroker

public CamelRoutesBroker(Broker next)

Method Detail

send

public void send(ProducerBrokerExchange producerExchange,
        Message message)
          throws Exception

Overide methods to pause the broker whilst camel routes are loaded

Specified by:

send in interface Region

Overrides:

send in class BrokerFilter

Parameters:

producerExchange - the environment the operation is being executed under.

Throws:

Exception - TODO

acknowledge

public void acknowledge(ConsumerBrokerExchange consumerExchange,
               MessageAck ack)
                 throws 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 BrokerFilter

Parameters:

consumerExchange - the environment the operation is being executed under.

Throws:

Exception - TODO

messagePull

public Response messagePull(ConnectionContext context,
                   MessagePull pull)
                     throws Exception

Description copied from interface: Region

Allows a consumer to pull a message from a queue

Specified by:

messagePull in interface Region

Overrides:

messagePull in class BrokerFilter

Throws:

Exception

processConsumerControl

public void processConsumerControl(ConsumerBrokerExchange consumerExchange,
                          ConsumerControl control)

Specified by:

processConsumerControl in interface Region

Overrides:

processConsumerControl in class BrokerFilter

reapplyInterceptor

public void reapplyInterceptor()

Specified by:

reapplyInterceptor in interface Region

Overrides:

reapplyInterceptor in class BrokerFilter

beginTransaction

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

Description copied from interface: Broker

Starts a transaction.

Specified by:

beginTransaction in interface Broker

Overrides:

beginTransaction in class BrokerFilter

Throws:

Exception - TODO

prepareTransaction

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

Description copied from interface: Broker

Prepares a transaction. Only valid for xa transactions.

Specified by:

prepareTransaction in interface Broker

Overrides:

prepareTransaction in class BrokerFilter

Returns:

id

Throws:

Exception - TODO

rollbackTransaction

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

Description copied from interface: Broker

Rollsback a transaction.

Specified by:

rollbackTransaction in interface Broker

Overrides:

rollbackTransaction in class BrokerFilter

Throws:

Exception - TODO

commitTransaction

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

Description copied from interface: Broker

Commits a transaction.

Specified by:

commitTransaction in interface Broker

Overrides:

commitTransaction in class BrokerFilter

Throws:

Exception - TODO

forgetTransaction

public void forgetTransaction(ConnectionContext context,
                     TransactionId transactionId)
                       throws Exception

Description copied from interface: Broker

Forgets a transaction.

Specified by:

forgetTransaction in interface Broker

Overrides:

forgetTransaction in class BrokerFilter

Throws:

Exception

preProcessDispatch

public void preProcessDispatch(MessageDispatch messageDispatch)

Description copied from interface: Broker

Notify the Broker that a dispatch is going to happen

Specified by:

preProcessDispatch in interface Broker

Overrides:

preProcessDispatch in class BrokerFilter

postProcessDispatch

public void postProcessDispatch(MessageDispatch messageDispatch)

Description copied from interface: Broker

Notify the Broker that a dispatch has happened

Specified by:

postProcessDispatch in interface Broker

Overrides:

postProcessDispatch in class BrokerFilter

sendToDeadLetterQueue

public boolean sendToDeadLetterQueue(ConnectionContext context,
                            MessageReference messageReference,
                            Subscription subscription,
                            Throwable poisonCause)

Description copied from interface: Broker

A message needs to go the a DLQ

Specified by:

sendToDeadLetterQueue in interface Broker

Overrides:

sendToDeadLetterQueue in class BrokerFilter

poisonCause - reason for dlq submission, may be null

Returns:

true if Message was placed in a DLQ false if discarded.

messageConsumed

public void messageConsumed(ConnectionContext context,
                   MessageReference messageReference)

Description copied from interface: Broker

called when message is consumed

Specified by:

messageConsumed in interface Broker

Overrides:

messageConsumed in class BrokerFilter

messageDelivered

public void messageDelivered(ConnectionContext context,
                    MessageReference messageReference)

Description copied from interface: Broker

Called when message is delivered to the broker

Specified by:

messageDelivered in interface Broker

Overrides:

messageDelivered in class BrokerFilter

messageDiscarded

public void messageDiscarded(ConnectionContext context,
                    Subscription sub,
                    MessageReference messageReference)

Description copied from interface: Broker

Called when a message is discarded - e.g. running low on memory This will happen only if the policy is enabled - e.g. non durable topics

Specified by:

messageDiscarded in interface Broker

Overrides:

messageDiscarded in class BrokerFilter

isFull

public void isFull(ConnectionContext context,
          Destination destination,
          Usage usage)

Description copied from interface: Broker

Called when a Usage reaches a limit

Specified by:

isFull in interface Broker

Overrides:

isFull in class BrokerFilter

nowMasterBroker

public void nowMasterBroker()

Description copied from interface: Broker

called when the broker becomes the master in a master/slave configuration

Specified by:

nowMasterBroker in interface Broker

Overrides:

nowMasterBroker in class BrokerFilter

getRoutesFile

public String getRoutesFile()

setRoutesFile

public void setRoutesFile(String routesFile)

getCheckPeriod

public int getCheckPeriod()

setCheckPeriod

public void setCheckPeriod(int checkPeriod)

start

public void start()
           throws Exception

Specified by:

start in interface Service

Overrides:

start in class BrokerFilter

Throws:

Exception

stop

public void stop()
          throws Exception

Specified by:

stop in interface Service

Overrides:

stop in class BrokerFilter

Throws:

Exception