I want a way to trace producer and consumer message activity. When a message was placed in a queue, when they were consumed, and the headers for those messages.
Is this the logging message interceptor? http://activemq.apache.org/logging-interceptor.html I’m playing with it and it’s difficult to use and consume the messages. For example, it’s unclear if a message is being added or removed from a queue… AKA produced/consumed. I’ll just get: 2015-02-10 23:46:34,303 INFO [ActiveMQ BrokerService[localhost] Task-2] org.apache.activemq.broker.util.LoggingBrokerPlugin preProcessDispatch: MessageDispatch {commandId = 0, responseRequired = false, consumerId = ID:Kevins-MacBook-Pro-2.local-64990-1423640790737-7:1:1:1, destination = topic://ActiveMQ.Advisory.Queue, message = ActiveMQMessage {commandId = 0, responseRequired = false, messageId = ID:Kevins-MacBook-Pro-2.local-64990-1423640790737-1:1:0:0:7, originalDestination = null, originalTransactionId = null, producerId = ID:Kevins-MacBook-Pro-2.local-64990-1423640790737-1:1:0:0, destination = topic://ActiveMQ.Advisory.Queue, transactionId = null, expiration = 0, timestamp = 0, arrival = 0, brokerInTime = 1423640794293, brokerOutTime = 0, correlationId = null, replyTo = null, persistent = false, type = Advisory, priority = 0, groupID = null, groupSequence = 0, targetConsumerId = null, compressed = false, userID = null, content = null, marshalledProperties = null, dataStructure = DestinationInfo {commandId = 0, responseRequired = false, connectionId = ID:Kevins-MacBook-Pro-2.local-64990-1423640790737-3:1, destination = queue://throttle-queue:source-task:pending:FGTLlMkQlcqxa2ou58VKIyyHIvw, operationType = 0, timeout = 0, brokerPath = null}, redeliveryCounter = 0, size = 1024, properties = {originBrokerURL=tcp://Kevins-MacBook-Pro-2.local:16161, originBrokerId=ID:Kevins-MacBook-Pro-2.local-64990-1423640790737-0:1, BrokerPath=localhost, originBrokerName=localhost}, readOnlyProperties = false, readOnlyBody = false, droppable = false, jmsXGroupFirstForConsumer = false}, redeliveryCounter = 0} 2015-02-10 23:46:34,307 INFO [ActiveMQ BrokerService[localhost] Task-1] org.apache.activemq.broker.util.LoggingBrokerPlugin preProcessDis -- Founder/CEO Spinn3r.com Location: *San Francisco, CA* blog: http://burtonator.wordpress.com … or check out my Google+ profile <https://plus.google.com/102718274791889610666/posts> <http://spinn3r.com>
