Apache/nifi
1
0
Fork 0
mirror of https://github.com/apache/nifi.git synced 2025-03-06 09:29:33 +00:00
Code Issues Packages Projects Releases Wiki Activity

NIFI-6885:

Browse Source 
- Fixed bug when calling logUnbuildableDestination with "jms_destination" instead of actual destination name value

Signed-off-by: Matthew Burgess <mattyb149@apache.org>

This closes #3895
This commit is contained in:
Joe Ferner 2019-11-19 10:29:46 -05:00 committed by Matthew Burgess
parent 0acdde827e
commit ae2b3d6b45
No known key found for this signature in database
GPG Key ID: 05D3DEB8126DAD24
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
nifi-nar-bundles/nifi-jms-bundle/nifi-jms-processors/src/main/java/org/apache/nifi/jms/processors/JMSPublisher.java
View File

@ -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