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 e64a71e95c87f8339ad80f3e6c70b34cff540822 Author: Otavio Rodolfo Piske <[email protected]> AuthorDate: Mon Jan 26 11:11:44 2026 +0000 (chores): modernize instanceof checks in camel-activemq --- .../org/apache/camel/component/activemq/ActiveMQComponent.java | 4 ++-- .../apache/camel/component/activemq/ActiveMQConfiguration.java | 4 ++-- .../component/activemq/OriginalDestinationPropagateStrategy.java | 4 ++-- .../component/activemq/converter/ActiveMQMessageConverter.java | 8 ++++---- 4 files changed, 10 insertions(+), 10 deletions(-) diff --git a/components/camel-activemq/src/main/java/org/apache/camel/component/activemq/ActiveMQComponent.java b/components/camel-activemq/src/main/java/org/apache/camel/component/activemq/ActiveMQComponent.java index d2df48853d24..119ca00a306d 100644 --- a/components/camel-activemq/src/main/java/org/apache/camel/component/activemq/ActiveMQComponent.java +++ b/components/camel-activemq/src/main/java/org/apache/camel/component/activemq/ActiveMQComponent.java @@ -78,8 +78,8 @@ public class ActiveMQComponent extends JmsComponent { */ public static ActiveMQComponent activeMQComponent(String brokerURL) { ActiveMQComponent answer = new ActiveMQComponent(); - if (answer.getConfiguration() instanceof ActiveMQConfiguration) { - ((ActiveMQConfiguration) answer.getConfiguration()).setBrokerURL(brokerURL); + if (answer.getConfiguration() instanceof ActiveMQConfiguration activeMQConfiguration) { + activeMQConfiguration.setBrokerURL(brokerURL); } return answer; diff --git a/components/camel-activemq/src/main/java/org/apache/camel/component/activemq/ActiveMQConfiguration.java b/components/camel-activemq/src/main/java/org/apache/camel/component/activemq/ActiveMQConfiguration.java index 0f32d9d36e85..cf10c7f8e48c 100644 --- a/components/camel-activemq/src/main/java/org/apache/camel/component/activemq/ActiveMQConfiguration.java +++ b/components/camel-activemq/src/main/java/org/apache/camel/component/activemq/ActiveMQConfiguration.java @@ -148,8 +148,8 @@ public class ActiveMQConfiguration extends JmsConfiguration { if (target instanceof DelegatingConnectionFactory dcf) { target = dcf.getTargetConnectionFactory(); } - if (target instanceof ActiveMQConnectionFactory) { - acf = (ActiveMQConnectionFactory) target; + if (target instanceof ActiveMQConnectionFactory activeMQConnectionFactory) { + acf = activeMQConnectionFactory; } if (acf != null) { diff --git a/components/camel-activemq/src/main/java/org/apache/camel/component/activemq/OriginalDestinationPropagateStrategy.java b/components/camel-activemq/src/main/java/org/apache/camel/component/activemq/OriginalDestinationPropagateStrategy.java index 51d3b450a4b0..7a0d66766e5d 100644 --- a/components/camel-activemq/src/main/java/org/apache/camel/component/activemq/OriginalDestinationPropagateStrategy.java +++ b/components/camel-activemq/src/main/java/org/apache/camel/component/activemq/OriginalDestinationPropagateStrategy.java @@ -40,12 +40,12 @@ public class OriginalDestinationPropagateStrategy implements MessageCreatedStrat if (exchange.getIn() instanceof JmsMessage) { JmsMessage msg = exchange.getIn(JmsMessage.class); Message jms = msg.getJmsMessage(); - if (jms instanceof ActiveMQMessage amq && message instanceof ActiveMQMessage) { + if (jms instanceof ActiveMQMessage amq && message instanceof ActiveMQMessage activeMQMessage) { if (amq.getOriginalDestination() == null) { ActiveMQDestination from = amq.getDestination(); if (from != null) { LOG.trace("Setting OriginalDestination: {} on {}", from, message); - ((ActiveMQMessage) message).setOriginalDestination(from); + activeMQMessage.setOriginalDestination(from); } } } diff --git a/components/camel-activemq/src/main/java/org/apache/camel/component/activemq/converter/ActiveMQMessageConverter.java b/components/camel-activemq/src/main/java/org/apache/camel/component/activemq/converter/ActiveMQMessageConverter.java index 935258edd982..629b256054dd 100644 --- a/components/camel-activemq/src/main/java/org/apache/camel/component/activemq/converter/ActiveMQMessageConverter.java +++ b/components/camel-activemq/src/main/java/org/apache/camel/component/activemq/converter/ActiveMQMessageConverter.java @@ -71,13 +71,13 @@ public class ActiveMQMessageConverter { private static ActiveMQMessage createActiveMQMessage(Exchange exchange) throws JMSException { Object body = exchange.getIn().getBody(); - if (body instanceof String) { + if (body instanceof String str) { ActiveMQTextMessage answer = new ActiveMQTextMessage(); - answer.setText((String) body); + answer.setText(str); return answer; - } else if (body instanceof Serializable) { + } else if (body instanceof Serializable serializable) { ActiveMQObjectMessage answer = new ActiveMQObjectMessage(); - answer.setObject((Serializable) body); + answer.setObject(serializable); return answer; } else { return new ActiveMQMessage();
