[camel] 14/17: (chores) camel-rocketmq: do not catch Throwable

[orpiske]

This is an automated email from the ASF dual-hosted git repository.

orpiske pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel.git

commit ba692344d6682298bb1f66747fe162de65a429bf
Author: Otavio Rodolfo Piske <angusyo...@gmail.com>
AuthorDate: Fri Jun 23 14:51:54 2023 +0200

    (chores) camel-rocketmq: do not catch Throwable
---
 .../main/java/org/apache/camel/component/rocketmq/RocketMQProducer.java | 2 +-
 .../java/org/apache/camel/component/rocketmq/reply/ReplyTimeoutMap.java | 2 +-
 2 files changed, 2 insertions(+), 2 deletions(-)

diff --git 
a/components/camel-rocketmq/src/main/java/org/apache/camel/component/rocketmq/RocketMQProducer.java
 
b/components/camel-rocketmq/src/main/java/org/apache/camel/component/rocketmq/RocketMQProducer.java
index 2eaa76ffc1e..e64305ff941 100644
--- 
a/components/camel-rocketmq/src/main/java/org/apache/camel/component/rocketmq/RocketMQProducer.java
+++ 
b/components/camel-rocketmq/src/main/java/org/apache/camel/component/rocketmq/RocketMQProducer.java
@@ -79,7 +79,7 @@ public class RocketMQProducer extends DefaultAsyncProducer {
             } else {
                 return processInOnly(exchange, callback);
             }
-        } catch (Throwable e) {
+        } catch (Exception e) {
             exchange.setException(e);
             callback.done(true);
             return true;
diff --git 
a/components/camel-rocketmq/src/main/java/org/apache/camel/component/rocketmq/reply/ReplyTimeoutMap.java
 
b/components/camel-rocketmq/src/main/java/org/apache/camel/component/rocketmq/reply/ReplyTimeoutMap.java
index 0ddc479d259..d85614d74a0 100644
--- 
a/components/camel-rocketmq/src/main/java/org/apache/camel/component/rocketmq/reply/ReplyTimeoutMap.java
+++ 
b/components/camel-rocketmq/src/main/java/org/apache/camel/component/rocketmq/reply/ReplyTimeoutMap.java
@@ -43,7 +43,7 @@ public class ReplyTimeoutMap extends 
DefaultTimeoutMap<String, ReplyHandler> {
             case Evict:
                 try {
                     handler.onTimeout(key);
-                } catch (Throwable e) {
+                } catch (Exception e) {
                     log.warn("Error processing onTimeout for messageKey: {} 
due: {}. " +
                              "This exception is ignored.",
                             key, e.getLocalizedMessage(), e);