From 76a9f98d7f43b0b23c7360a2d21ee81f5d19309e Mon Sep 17 00:00:00 2001 From: Mike Moser Date: Wed, 5 Sep 2018 15:49:44 -0400 Subject: [PATCH] NIFI-3531 Catch and rethrow generic Exception to handle RuntimeExceptions, and allow test to pass This closes #2931. Signed-off-by: Brandon Devries --- .../main/java/org/apache/nifi/jms/processors/JMSConsumer.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/nifi-nar-bundles/nifi-jms-bundle/nifi-jms-processors/src/main/java/org/apache/nifi/jms/processors/JMSConsumer.java b/nifi-nar-bundles/nifi-jms-bundle/nifi-jms-processors/src/main/java/org/apache/nifi/jms/processors/JMSConsumer.java index cf22175217..a2c73b4e3b 100644 --- a/nifi-nar-bundles/nifi-jms-bundle/nifi-jms-processors/src/main/java/org/apache/nifi/jms/processors/JMSConsumer.java +++ b/nifi-nar-bundles/nifi-jms-bundle/nifi-jms-processors/src/main/java/org/apache/nifi/jms/processors/JMSConsumer.java @@ -122,7 +122,7 @@ final class JMSConsumer extends JMSWorker { // and if CLIENT_ACKNOWLEDGE is set. consumerCallback.accept(response); acknowledge(message, session); - } catch (JMSException e) { + } catch (Exception e) { // We need to call recover to ensure that in the event of // abrupt end or exception the current session will stop message // delivery and restart with the oldest unacknowledged message