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 e74898f2e3454688b419058c9a7e215bd36022a0 Author: Otavio Rodolfo Piske <[email protected]> AuthorDate: Mon Jan 26 11:13:28 2026 +0000 (chores): modernize instanceof checks in camel-activemq6 --- .../org/apache/camel/component/activemq6/ActiveMQComponent.java | 4 ++-- .../apache/camel/component/activemq6/ActiveMQConfiguration.java | 4 ++-- .../component/activemq6/OriginalDestinationPropagateStrategy.java | 4 ++-- .../component/activemq6/converter/ActiveMQMessageConverter.java | 8 ++++---- 4 files changed, 10 insertions(+), 10 deletions(-) diff --git a/components/camel-activemq6/src/main/java/org/apache/camel/component/activemq6/ActiveMQComponent.java b/components/camel-activemq6/src/main/java/org/apache/camel/component/activemq6/ActiveMQComponent.java index a3c263d25b25..c75b4fc8ed70 100644 --- a/components/camel-activemq6/src/main/java/org/apache/camel/component/activemq6/ActiveMQComponent.java +++ b/components/camel-activemq6/src/main/java/org/apache/camel/component/activemq6/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-activemq6/src/main/java/org/apache/camel/component/activemq6/ActiveMQConfiguration.java b/components/camel-activemq6/src/main/java/org/apache/camel/component/activemq6/ActiveMQConfiguration.java index fe5e46535ab1..c37b68c6e582 100644 --- a/components/camel-activemq6/src/main/java/org/apache/camel/component/activemq6/ActiveMQConfiguration.java +++ b/components/camel-activemq6/src/main/java/org/apache/camel/component/activemq6/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-activemq6/src/main/java/org/apache/camel/component/activemq6/OriginalDestinationPropagateStrategy.java b/components/camel-activemq6/src/main/java/org/apache/camel/component/activemq6/OriginalDestinationPropagateStrategy.java index 195fb747bb8d..dfce94678145 100644 --- a/components/camel-activemq6/src/main/java/org/apache/camel/component/activemq6/OriginalDestinationPropagateStrategy.java +++ b/components/camel-activemq6/src/main/java/org/apache/camel/component/activemq6/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-activemq6/src/main/java/org/apache/camel/component/activemq6/converter/ActiveMQMessageConverter.java b/components/camel-activemq6/src/main/java/org/apache/camel/component/activemq6/converter/ActiveMQMessageConverter.java index 4cdbef0bb15d..0ae2d43ef562 100644 --- a/components/camel-activemq6/src/main/java/org/apache/camel/component/activemq6/converter/ActiveMQMessageConverter.java +++ b/components/camel-activemq6/src/main/java/org/apache/camel/component/activemq6/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();
