Repository: nifi
Updated Branches:
  refs/heads/0.x d9ec36550 -> ff4b91e70


NIFI-1549: Fix JMSConsumer exception

This closes #539


Project: http://git-wip-us.apache.org/repos/asf/nifi/repo
Commit: http://git-wip-us.apache.org/repos/asf/nifi/commit/ff4b91e7
Tree: http://git-wip-us.apache.org/repos/asf/nifi/tree/ff4b91e7
Diff: http://git-wip-us.apache.org/repos/asf/nifi/diff/ff4b91e7

Branch: refs/heads/0.x
Commit: ff4b91e70750307e7a459f8b92fee1dedb7193d5
Parents: d9ec365
Author: Joshi <[email protected]>
Authored: Thu Jun 16 20:51:49 2016 -0700
Committer: Oleg Zhurakousky <[email protected]>
Committed: Fri Jun 17 12:18:20 2016 -0400

----------------------------------------------------------------------
 .../main/java/org/apache/nifi/processors/standard/JmsConsumer.java | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/nifi/blob/ff4b91e7/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/JmsConsumer.java
----------------------------------------------------------------------
diff --git 
a/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/JmsConsumer.java
 
b/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/JmsConsumer.java
index ea70d52..c820174 100644
--- 
a/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/JmsConsumer.java
+++ 
b/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/JmsConsumer.java
@@ -197,7 +197,7 @@ public abstract class JmsConsumer extends AbstractProcessor 
{
                             final byte[] messageBody = 
JmsFactory.createByteArray(message);
                             out.write(messageBody);
                         } catch (final JMSException e) {
-                            throw new ProcessException("Failed to receive JMS 
Message due to {}", e);
+                            throw new ProcessException("Failed to receive JMS 
Message due to " + e.getMessage(), e);
                         }
                     }
                 });

Reply via email to