You are viewing a plain text version of this content. The canonical link for it is here.

Posted to issues@nifi.apache.org by "Mehdi Avdi (JIRA)" <ji...@apache.org> on 2017/08/17 14:39:00 UTC

[jira] [Created] (NIFI-4303) RabbitMQConsumer: Publish the message routing key as an attribute to flowfile

Mehdi Avdi created NIFI-4303:
--------------------------------

             Summary: RabbitMQConsumer: Publish the message routing key as an attribute to flowfile
                 Key: NIFI-4303
                 URL: https://issues.apache.org/jira/browse/NIFI-4303
             Project: Apache NiFi
          Issue Type: Improvement
            Reporter: Mehdi Avdi
         Attachments: Screen Shot 2017-08-17 at 15.35.57.png

When retrieving messages from a queue that is bound to a topic exchange, message come with a routing key which might contain crucial identifying information about where the message came from.

Current implementation of the RabbitMQConsumer processor doesn't publish this property of the message to the attributes of the flowfile it creates. Can this be added?

I found the relevant code here: https://github.com/apache/nifi/blob/d838f61291d2582592754a37314911b701c6891b/nifi-nar-bundles/nifi-amqp-bundle/nifi-amqp-processors/src/main/java/org/apache/nifi/amqp/processors/AMQPUtils.java#L95

I have very sketchy Java skills, otherwise would submit a PR.



--
This message was sent by Atlassian JIRA
(v6.4.14#64029)