[rabbitmq-discuss] Who conusmed messages - Can it be done through trace?

[Srinath Sridharan -X (srinatsr - ZENSAR TECHNOLOGIES INC at Cisco)]

>From the following how do I know who consumed (delivered to whom)

Firehose notification format
The firehose publishes messages to the topic exchange amq.rabbitmq.trace with
*        routing key either "publish.exchangename", for messages entering the broker, or "deliver.queuename", for messages leaving the broker;
*        headers containing metadata about the original message:
Header

Type

Description

exchange_name

longstr

name of the exchange to which the message was published

routing_keys

array

routing key plus contents of CC and BCC headers<http://www.rabbitmq.com/sender-selected.html>

properties

table

content properties<http://www.rabbitmq.com/amqp-0-9-1-reference.html#class.basic>

node

longstr

Erlang node on which the trace message was generated

redelivered

signedint

whether the message has its redelivered flag set (messages leaving the broker only)

*        body corresponding to the body of the original message


Regards ...*
Srinath

From: rabbitmq-discuss [mailto:rabbitmq-discuss-bounces at lists.rabbitmq.com] On Behalf Of Srinath Sridharan -X (srinatsr - ZENSAR TECHNOLOGIES INC at Cisco)
Sent: Thursday, May 08, 2014 1:52 PM
To: Discussions about RabbitMQ
Subject: Re: [rabbitmq-discuss] Who conusmed messages - Can it be done through trace?

Anyone please help

Regards ...*
Srinath

From: rabbitmq-discuss [mailto:rabbitmq-discuss-bounces at lists.rabbitmq.com] On Behalf Of Srinath Sridharan -X (srinatsr - ZENSAR TECHNOLOGIES INC at Cisco)
Sent: Thursday, May 08, 2014 12:55 PM
To: rabbitmq-discuss at lists.rabbitmq.com<mailto:rabbitmq-discuss at lists.rabbitmq.com>
Subject: [rabbitmq-discuss] Who conusmed messages - Can it be done through trace?

Hello All,

I have bind my queue with trace and log exchange,  I need to know which node actually consumed the message.

How to find out,

@Override
       public void onMessage(Message message, Channel channel) throws Exception {

             QueueMonitorRespone queueMonitorRespone = new QueueMonitorRespone();
              queueMonitorRespone.setExchange(message.getMessageProperties().getReceivedExchange());
              queueMonitorRespone.setRoutingKey(message.getMessageProperties().getReceivedRoutingKey());
              queueMonitorRespone.setDeliveryMode(message.getMessageProperties().getDeliveryMode().name());
              queueMonitorRespone.setTimestamp(message.getMessageProperties().getTimestamp());
             queueMonitorRespone.setMessageBody(new String(message.getBody()));

I getting trace log msgs and bind my queue to trace log.  From those messages I am getting the above info.

I am getting it delivered, but who acutally consumed?
Regards ...*
Srinath

-------------- next part --------------
An HTML attachment was scrubbed...
URL: <http://lists.rabbitmq.com/pipermail/rabbitmq-discuss/attachments/20140508/98fb0565/attachment.html>