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

• Type: Improvement
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 1.13.0
• Component/s: Extensions
• Assignee: Dominik Hendzel
• Reporter: Mehdi Avdi
• Created: 17/Aug/17 14:38
• Updated: 28/Sep/20 21:14
• Resolved: 28/Sep/20 21:14

Description

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.

Issue Links

• links to: GitHub Pull Request #4464