You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@nifi.apache.org by ma...@apache.org on 2019/11/21 21:36:06 UTC
[nifi] branch master updated: NIFI-6885: - Fixed bug when calling
logUnbuildableDestination with "jms_destination" instead of actual
destination name value
This is an automated email from the ASF dual-hosted git repository.
mattyb149 pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/nifi.git
The following commit(s) were added to refs/heads/master by this push:
new ae2b3d6 NIFI-6885: - Fixed bug when calling logUnbuildableDestination with "jms_destination" instead of actual destination name value
ae2b3d6 is described below
commit ae2b3d6b45fafb83bedd86f4d6da8d74a4b6ee6d
Author: Joe Ferner <jo...@gmail.com>
AuthorDate: Tue Nov 19 10:29:46 2019 -0500
NIFI-6885:
- Fixed bug when calling logUnbuildableDestination with "jms_destination" instead of actual destination name value
Signed-off-by: Matthew Burgess <ma...@apache.org>
This closes #3895
---
.../src/main/java/org/apache/nifi/jms/processors/JMSPublisher.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git a/nifi-nar-bundles/nifi-jms-bundle/nifi-jms-processors/src/main/java/org/apache/nifi/jms/processors/JMSPublisher.java b/nifi-nar-bundles/nifi-jms-bundle/nifi-jms-processors/src/main/java/org/apache/nifi/jms/processors/JMSPublisher.java
index 506de49..1ea61b6 100644
--- a/nifi-nar-bundles/nifi-jms-bundle/nifi-jms-processors/src/main/java/org/apache/nifi/jms/processors/JMSPublisher.java
+++ b/nifi-nar-bundles/nifi-jms-bundle/nifi-jms-processors/src/main/java/org/apache/nifi/jms/processors/JMSPublisher.java
@@ -105,14 +105,14 @@ final class JMSPublisher extends JMSWorker {
if (destination != null) {
message.setJMSReplyTo(destination);
} else {
- logUnbuildableDestination(entry.getKey(), JmsHeaders.REPLY_TO);
+ logUnbuildableDestination(entry.getValue(), JmsHeaders.REPLY_TO);
}
} else if (entry.getKey().equals(JmsHeaders.DESTINATION)) {
Destination destination = buildDestination(entry.getValue());
if (destination != null) {
message.setJMSDestination(destination);
} else {
- logUnbuildableDestination(entry.getKey(), JmsHeaders.DESTINATION);
+ logUnbuildableDestination(entry.getValue(), JmsHeaders.DESTINATION);
}
} else {
// not a special attribute handled above, so send it as a property using the specified property type