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 3084fa4c86bff0d9879125aadd030a8529f17955
Author: Otavio R. Piske <angusyo...@gmail.com>
AuthorDate: Sat Jan 27 20:22:22 2024 +0100

    (chores) camel-jms: minor code cleanups
    
    - removed unused throws declaration
    - use isEmpty
    - use final fields when possible
    - reduced unnecessary field visibility
    
    Signed-off-by: Otavio R. Piske <angusyo...@gmail.com>
---
 .../main/java/org/apache/camel/component/jms/JmsConfiguration.java    | 4 ++--
 .../main/java/org/apache/camel/component/jms/JmsSendDynamicAware.java | 2 +-
 .../java/org/apache/camel/component/jms/reply/QueueReplyManager.java  | 3 +--
 3 files changed, 4 insertions(+), 5 deletions(-)

diff --git 
a/components/camel-jms/src/main/java/org/apache/camel/component/jms/JmsConfiguration.java
 
b/components/camel-jms/src/main/java/org/apache/camel/component/jms/JmsConfiguration.java
index 74e27a5b011..433e386bc6e 100644
--- 
a/components/camel-jms/src/main/java/org/apache/camel/component/jms/JmsConfiguration.java
+++ 
b/components/camel-jms/src/main/java/org/apache/camel/component/jms/JmsConfiguration.java
@@ -557,7 +557,7 @@ public class JmsConfiguration implements Cloneable {
     }
 
     public static class CamelJmsTemplate extends JmsTemplate {
-        private JmsConfiguration config;
+        private final JmsConfiguration config;
 
         public CamelJmsTemplate(JmsConfiguration config, ConnectionFactory 
connectionFactory) {
             super(connectionFactory);
@@ -1621,7 +1621,7 @@ public class JmsConfiguration implements Cloneable {
             }
         }
 
-        if (endpoint.getSelector() != null && endpoint.getSelector().length() 
!= 0) {
+        if (endpoint.getSelector() != null && 
!endpoint.getSelector().isEmpty()) {
             container.setMessageSelector(endpoint.getSelector());
         }
 
diff --git 
a/components/camel-jms/src/main/java/org/apache/camel/component/jms/JmsSendDynamicAware.java
 
b/components/camel-jms/src/main/java/org/apache/camel/component/jms/JmsSendDynamicAware.java
index d5877c83aa9..4e7aa1b2f4a 100644
--- 
a/components/camel-jms/src/main/java/org/apache/camel/component/jms/JmsSendDynamicAware.java
+++ 
b/components/camel-jms/src/main/java/org/apache/camel/component/jms/JmsSendDynamicAware.java
@@ -90,7 +90,7 @@ public class JmsSendDynamicAware extends ServiceSupport 
implements SendDynamicAw
         final String destinationName = parseDestinationName(entry.getUri());
         return new Processor() {
             @Override
-            public void process(Exchange exchange) throws Exception {
+            public void process(Exchange exchange) {
                 
exchange.getMessage().setHeader(JmsConstants.JMS_DESTINATION_NAME, 
destinationName);
             }
         };
diff --git 
a/components/camel-jms/src/main/java/org/apache/camel/component/jms/reply/QueueReplyManager.java
 
b/components/camel-jms/src/main/java/org/apache/camel/component/jms/reply/QueueReplyManager.java
index dda1293838f..c0697cf329d 100644
--- 
a/components/camel-jms/src/main/java/org/apache/camel/component/jms/reply/QueueReplyManager.java
+++ 
b/components/camel-jms/src/main/java/org/apache/camel/component/jms/reply/QueueReplyManager.java
@@ -41,7 +41,6 @@ import 
org.springframework.jms.support.destination.DestinationResolver;
 public class QueueReplyManager extends ReplyManagerSupport {
 
     private String replyToSelectorValue;
-    private MessageSelectorCreator dynamicMessageSelector;
 
     public QueueReplyManager(CamelContext camelContext) {
         super(camelContext);
@@ -238,7 +237,7 @@ public class QueueReplyManager extends ReplyManagerSupport {
                         endpoint.getReplyTo(), fixedMessageSelector, answer);
             } else {
                 // use a dynamic message selector which will select the 
message we want to receive as reply
-                dynamicMessageSelector = new 
MessageSelectorCreator(correlation);
+                MessageSelectorCreator dynamicMessageSelector = new 
MessageSelectorCreator(correlation);
                 answer = new SharedQueueMessageListenerContainer(endpoint, 
dynamicMessageSelector);
                 log.debug("Using shared queue: {} with dynamic message 
selector as reply listener: {}", endpoint.getReplyTo(),
                         answer);

Reply via email to