[
https://issues.apache.org/jira/browse/NIFI-7865?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17478227#comment-17478227
]
ASF subversion and git services commented on NIFI-7865:
-------------------------------------------------------
Commit e603b0179bf46ef26bbf4713ae68553b19d4c485 in nifi's branch
refs/heads/main from sedadgn
[ https://gitbox.apache.org/repos/asf?p=nifi.git;h=e603b017 ]
NIFI-7865 amqp$header is splitted in the wrong way for "," and "}"
This PR introduces 2 new properties for the ConsumeAMQP processor
And one new property for PublishAMQP
This allows to configure the processors to use escaping for commas and to
consistently not use curly braces in the amqp$header attribute.
The default values ensure backwards compatibility.
This closes #5458.
Signed-off-by: Kevin Doran <kdo...@apache.org>
> amqp$header is splitted in the wrong way for "," and "}"
> --------------------------------------------------------
>
> Key: NIFI-7865
> URL: https://issues.apache.org/jira/browse/NIFI-7865
> Project: Apache NiFi
> Issue Type: Bug
> Components: Extensions
> Affects Versions: 1.12.0
> Environment: rabbbitmq 3.7.7
> nifi 1.12.0
> Reporter: Tobias Kellermann
> Assignee: Seda Dogan
> Priority: Major
> Labels: amqp, publish
> Time Spent: 7h 50m
> Remaining Estimate: 0h
>
> 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
> {code:java}
> headers: {code}
> {code:java}
> encoding: UTF-8
> objectid: (226
> preprocessing: false
> type: XML
> {sender: erp-send{code}
> but it should be
> {code:java}
> headers:
> encoding: UTF-8
> objectid: (226,0,0)
> preprocessing: false
> type: XML
> sender: erp-send{code}
> 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 ",",
--
This message was sent by Atlassian Jira
(v8.20.1#820001)
