org.apache.activemq.broker.util: public class: TraceBrokerPathPlugin

org.apache.activemq.broker.util
public class: TraceBrokerPathPlugin [javadoc | source]

java.lang.Object
   org.apache.activemq.broker.MutableBrokerFilter
      org.apache.activemq.broker.BrokerPluginSupport
         org.apache.activemq.broker.util.TraceBrokerPathPlugin

All Implemented Interfaces:
BrokerPlugin, Broker

The TraceBrokerPathPlugin can be used in a network of Brokers. Each Broker that has the plugin configured, will add it's brokerName to the content of a JMS Property. If all Brokers have this property enabled, the path the message actually took through the network can be seen in the defined property.

org.apache.xbean.XBean: element - ="traceBrokerPathPlugin"

version: $ - Revision$

Fields inherited from org.apache.activemq.broker.MutableBrokerFilter:
next

Method from org.apache.activemq.broker.util.TraceBrokerPathPlugin Summary:
getStampProperty, preProcessDispatch, setStampProperty

Methods from org.apache.activemq.broker.BrokerPluginSupport:
installPlugin

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 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.util.TraceBrokerPathPlugin Detail:
public String getStampProperty() { return stampProperty; }
public void preProcessDispatch(MessageDispatch messageDispatch) { try { String brokerStamp = (String)messageDispatch.getMessage().getProperty(getStampProperty()); if (brokerStamp == null) { brokerStamp = getBrokerName(); } else { brokerStamp += "," + getBrokerName(); } messageDispatch.getMessage().setProperty(getStampProperty(), brokerStamp); } catch (IOException ioe) { LOG.warn("Setting broker property failed " + ioe, ioe); } super.preProcessDispatch(messageDispatch); }
public void setStampProperty(String stampProperty) { this.stampProperty = stampProperty; }

Method from org.apache.activemq.broker.util.TraceBrokerPathPlugin Detail:

 public String getStampProperty() {
		return stampProperty;
}

 public  void preProcessDispatch(MessageDispatch messageDispatch) {
		try {
    		String brokerStamp = (String)messageDispatch.getMessage().getProperty(getStampProperty());
    		if (brokerStamp == null) {
    			brokerStamp = getBrokerName();
    		} else {
    			brokerStamp += "," + getBrokerName();
    		}
    		messageDispatch.getMessage().setProperty(getStampProperty(), brokerStamp);
		} catch (IOException ioe) {
			LOG.warn("Setting broker property failed " + ioe, ioe);
		}
		super.preProcessDispatch(messageDispatch);
}

 public  void setStampProperty(String stampProperty) {
		this.stampProperty = stampProperty;
}