[NIFI-7865] amqp$header is splitted in the wrong way for "," and "}"

• Type: Bug
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 1.12.0
• Fix Version/s: 1.16.0
• Component/s: Extensions
• Labels: amqp publish
• Environment: rabbbitmq 3.7.7 ; nifi 1.12.0
• Flags: Patch, Important
• Assignee: Seda Dogan
• Reporter: Tobias Kellermann
• Created: 30/Sep/20 12:33
• Updated: 03/Feb/22 21:29
• Resolved: 03/Feb/22 21:29

Description

I have connected the both processors ConsumeAMQP and PublishAMQP.
When I get a Message from the queue the following attribute
amqp$headers value = {sender=erp-send, preprocessing=false, encoding=UTF-8, type=XML, objectid=(226,0,0)}
is set. I would like publish this message with the same Header but the values of the header in rabbitmq is

headers: 

encoding: UTF-8
 objectid: (226
 preprocessing: false
 type: XML
 {sender: erp-send

but it should be

headers: 
 encoding: UTF-8
 objectid: (226,0,0)
 preprocessing: false
 type: XML
 sender: erp-send

The problem seems to in the class org.apache.nifi.amqp.processors.PublishAMQP in the function private Map<String, Object> validateAMQPHeaderProperty(String amqpPropValue) because of the spit only with ",",

Issue Links

• links to: GitHub Pull Request #5458