spring-integration-jms minor changes:

1. add Javadoc for few classes.
2. use pattern matching for instanceof

Signed-off-by: Jiandong Ma <[email protected]>

Author: mjd507

spring-integration-jms/src/main/java/org/springframework/integration/jms/AbstractJmsChannel.java

@@ -1,5 +1,5 @@
 /*
- * Copyright 2002-2024 the original author or authors.
+ * Copyright 2002-2025 the original author or authors.
  *
  * Licensed under the Apache License, Version 2.0 (the "License");
  * you may not use this file except in compliance with the License.
@@ -23,9 +23,17 @@
 import org.springframework.util.Assert;
 
 /**
+ * A base {@link AbstractMessageChannel} implementation for JMS-backed message channels.
+ *
+ * <p>When producer and consumer for a JMS destination are in the same application
+ * and process, instead of using a pair of inbound and outbound adapters, it is also
+ * possible to use a single message channel.
+ *
  * @author Mark Fisher
  * @author Gary Russell
  * @since 2.0
+ * @see PollableJmsChannel
+ * @see SubscribableJmsChannel
  */
 public abstract class AbstractJmsChannel extends AbstractMessageChannel {
 

spring-integration-jms/src/main/java/org/springframework/integration/jms/ChannelPublishingJmsMessageListener.java

@@ -1,5 +1,5 @@
 /*
- * Copyright 2002-2024 the original author or authors.
+ * Copyright 2002-2025 the original author or authors.
  *
  * Licensed under the Apache License, Version 2.0 (the "License");
  * you may not use this file except in compliance with the License.
@@ -406,8 +406,8 @@ public void onMessage(jakarta.jms.Message jmsMessage, Session session) throws JM
 				headers.put(IntegrationMessageHeaderAccessor.DELIVERY_ATTEMPT, new AtomicInteger());
 			}
 			requestMessage =
-					(result instanceof Message<?>) ?
-							this.messageBuilderFactory.fromMessage((Message<?>) result).copyHeaders(headers).build() :
+					result instanceof Message<?> message ?
+							this.messageBuilderFactory.fromMessage(message).copyHeaders(headers).build() :
 							this.messageBuilderFactory.withPayload(result).copyHeaders(headers).build();
 		}
 		catch (RuntimeException e) {

spring-integration-jms/src/main/java/org/springframework/integration/jms/DefaultJmsHeaderMapper.java

@@ -1,5 +1,5 @@
 /*
- * Copyright 2002-2024 the original author or authors.
+ * Copyright 2002-2025 the original author or authors.
  *
  * Licensed under the Apache License, Version 2.0 (the "License");
  * you may not use this file except in compliance with the License.
@@ -159,9 +159,9 @@ private void populateCorrelationIdPropertyFromHeaders(MessageHeaders headers, ja
 		if (jmsCorrelationId instanceof Number) {
 			jmsCorrelationId = jmsCorrelationId.toString();
 		}
-		if (jmsCorrelationId instanceof String) {
+		if (jmsCorrelationId instanceof String jmsCorrelationIdStr) {
 			try {
-				jmsMessage.setJMSCorrelationID((String) jmsCorrelationId);
+				jmsMessage.setJMSCorrelationID(jmsCorrelationIdStr);
 			}
 			catch (Exception ex) {
 				LOGGER.info("Failed to set JMSCorrelationID, skipping", ex);
@@ -171,9 +171,9 @@ private void populateCorrelationIdPropertyFromHeaders(MessageHeaders headers, ja
 
 	private void populateReplyToPropertyFromHeaders(MessageHeaders headers, jakarta.jms.Message jmsMessage) {
 		Object jmsReplyTo = headers.get(JmsHeaders.REPLY_TO);
-		if (jmsReplyTo instanceof Destination) {
+		if (jmsReplyTo instanceof Destination destination) {
 			try {
-				jmsMessage.setJMSReplyTo((Destination) jmsReplyTo);
+				jmsMessage.setJMSReplyTo(destination);
 			}
 			catch (Exception ex) {
 				LOGGER.info("Failed to set JMSReplyTo, skipping", ex);
@@ -183,9 +183,9 @@ private void populateReplyToPropertyFromHeaders(MessageHeaders headers, jakarta.
 
 	private void populateTypePropertyFromHeaders(MessageHeaders headers, jakarta.jms.Message jmsMessage) {
 		Object jmsType = headers.get(JmsHeaders.TYPE);
-		if (jmsType instanceof String) {
+		if (jmsType instanceof String jmsTypeStr) {
 			try {
-				jmsMessage.setJMSType((String) jmsType);
+				jmsMessage.setJMSType(jmsTypeStr);
 			}
 			catch (Exception ex) {
 				LOGGER.info("Failed to set JMSType, skipping", ex);

spring-integration-jms/src/main/java/org/springframework/integration/jms/DynamicJmsTemplate.java

@@ -1,5 +1,5 @@
 /*
- * Copyright 2002-2021 the original author or authors.
+ * Copyright 2002-2025 the original author or authors.
  *
  * Licensed under the Apache License, Version 2.0 (the "License");
  * you may not use this file except in compliance with the License.
@@ -24,6 +24,15 @@
 import org.springframework.util.Assert;
 
 /**
+ * A {@code JmsTemplate} implementation used by {@link JmsSendingMessageHandler} for
+ * propagating QoS properties from the request message into the underlying {@code
+ * producer.send(message, getDeliveryMode(), getPriority(), getTimeToLive())} API.
+ *
+ * <p>Propagation is only applied when {@code explicitQosEnabled} is true.
+ *
+ * <p>if {@code receiveTimeout} has not been explicitly set, default will be -1 if
+ * we get {@link CachingConnectionFactory} and it is with {@code cacheConsumers},
+ * otherwise 1 second.
  * @author Mark Fisher
  * @author Artem Bilan
  *
@@ -45,8 +54,8 @@ public void setReceiveTimeout(long receiveTimeout) {
 	public void setConnectionFactory(ConnectionFactory connectionFactory) {
 		super.setConnectionFactory(connectionFactory);
 		if (!this.receiveTimeoutExplicitlySet) {
-			if (connectionFactory instanceof CachingConnectionFactory &&
-					((CachingConnectionFactory) connectionFactory).isCacheConsumers()) {
+			if (connectionFactory instanceof CachingConnectionFactory cachingConnectionFactory &&
+					cachingConnectionFactory.isCacheConsumers()) {
 				super.setReceiveTimeout(JmsDestinationAccessor.RECEIVE_TIMEOUT_NO_WAIT);
 			}
 			else {

spring-integration-jms/src/main/java/org/springframework/integration/jms/JmsDestinationPollingSource.java

@@ -1,5 +1,5 @@
 /*
- * Copyright 2002-2024 the original author or authors.
+ * Copyright 2002-2025 the original author or authors.
  *
  * Licensed under the Apache License, Version 2.0 (the "License");
  * you may not use this file except in compliance with the License.
@@ -137,8 +137,8 @@ protected Object doReceive() {
 				}
 			}
 			AbstractIntegrationMessageBuilder<?> builder =
-					(object instanceof Message)
-							? getMessageBuilderFactory().fromMessage((Message<?>) object)
+					(object instanceof Message<?> message)
+							? getMessageBuilderFactory().fromMessage(message)
 							: getMessageBuilderFactory().withPayload(object);
 			return builder.copyHeadersIfAbsent(mappedHeaders);
 		}
@@ -148,7 +148,7 @@ protected Object doReceive() {
 	}
 
 	private jakarta.jms.Message doReceiveJmsMessage() {
-		jakarta.jms.Message jmsMessage = null;
+		jakarta.jms.Message jmsMessage;
 		if (this.destination != null) {
 			jmsMessage = this.jmsTemplate.receiveSelected(this.destination, this.messageSelector);
 		}

spring-integration-jms/src/main/java/org/springframework/integration/jms/JmsInboundGateway.java

@@ -1,5 +1,5 @@
 /*
- * Copyright 2016-2023 the original author or authors.
+ * Copyright 2016-2025 the original author or authors.
  *
  * Licensed under the Apache License, Version 2.0 (the "License");
  * you may not use this file except in compliance with the License.
@@ -109,7 +109,7 @@ public void setShouldTrack(boolean shouldTrack) {
 	/**
 	 * Set to {@code false} to prevent listener container shutdown when the endpoint is stopped.
 	 * Then, if so configured, any cached consumer(s) in the container will remain.
-	 * Otherwise, the shared connection and will be closed and the listener invokers shut
+	 * Otherwise, the shared connection will be closed and the listener invokers shut
 	 * down; this behavior is new starting with version 5.1. Default: true.
 	 * @param shutdownContainerOnStop false to not shutdown.
 	 * @since 5.1

spring-integration-jms/src/main/java/org/springframework/integration/jms/JmsMessageDrivenEndpoint.java

@@ -1,5 +1,5 @@
 /*
- * Copyright 2002-2023 the original author or authors.
+ * Copyright 2002-2025 the original author or authors.
  *
  * Licensed under the Apache License, Version 2.0 (the "License");
  * you may not use this file except in compliance with the License.
@@ -140,7 +140,7 @@ public void setShouldTrack(boolean shouldTrack) {
 	/**
 	 * Set to {@code false} to prevent listener container shutdown when the endpoint is stopped.
 	 * Then, if so configured, any cached consumer(s) in the container will remain.
-	 * Otherwise, the shared connection and will be closed and the listener invokers shut
+	 * Otherwise, the shared connection will be closed and the listener invokers shut
 	 * down; this behavior is new starting with version 5.1. Default: true.
 	 * @param shutdownContainerOnStop false to not shutdown.
 	 * @since 5.1

spring-integration-jms/src/main/java/org/springframework/integration/jms/JmsOutboundGateway.java

@@ -1,5 +1,5 @@
 /*
- * Copyright 2002-2024 the original author or authors.
+ * Copyright 2002-2025 the original author or authors.
  *
  * Licensed under the Apache License, Version 2.0 (the "License");
  * you may not use this file except in compliance with the License.
@@ -467,11 +467,11 @@ private Destination determineRequestDestination(Message<?> message, Session sess
 		}
 		if (this.requestDestinationExpressionProcessor != null) {
 			Object result = this.requestDestinationExpressionProcessor.processMessage(message);
-			if (result instanceof Destination) {
-				return (Destination) result;
+			if (result instanceof Destination destination) {
+				return destination;
 			}
-			if (result instanceof String) {
-				return resolveRequestDestination((String) result, session);
+			if (result instanceof String destinationName) {
+				return resolveRequestDestination(destinationName, session);
 			}
 			throw new MessageDeliveryException(message,
 					"Evaluation of requestDestinationExpression failed " +
@@ -496,11 +496,11 @@ private Destination determineReplyDestination(Message<?> message, Session sessio
 		}
 		if (this.replyDestinationExpressionProcessor != null) {
 			Object result = this.replyDestinationExpressionProcessor.processMessage(message);
-			if (result instanceof Destination) {
-				return (Destination) result;
+			if (result instanceof Destination destination) {
+				return destination;
 			}
-			if (result instanceof String) {
-				return resolveReplyDestination((String) result, session);
+			if (result instanceof String destinationName) {
+				return resolveReplyDestination(destinationName, session);
 			}
 			throw new MessageDeliveryException(message,
 					"Evaluation of replyDestinationExpression failed to produce a Destination or destination name. " +
@@ -771,8 +771,8 @@ protected Object handleRequestMessage(final Message<?> requestMessage) {
 				}
 			}
 
-			if (reply instanceof jakarta.jms.Message) {
-				return buildReply((jakarta.jms.Message) reply);
+			if (reply instanceof jakarta.jms.Message jmsMessage) {
+				return buildReply(jmsMessage);
 			}
 			else {
 				return reply;
@@ -799,8 +799,8 @@ private AbstractIntegrationMessageBuilder<?> buildReply(jakarta.jms.Message jmsR
 			// do not propagate back the gateway's internal correlation id
 			jmsReplyHeaders.remove(this.correlationKey);
 		}
-		if (result instanceof Message) {
-			return getMessageBuilderFactory().fromMessage((Message<?>) result).copyHeaders(jmsReplyHeaders);
+		if (result instanceof Message<?> message) {
+			return getMessageBuilderFactory().fromMessage(message).copyHeaders(jmsReplyHeaders);
 		}
 		else {
 			return getMessageBuilderFactory().withPayload(result).copyHeaders(jmsReplyHeaders);
@@ -850,8 +850,8 @@ private Object sendAndReceiveWithContainer(Message<?> requestMessage) throws JMS
 			 * Remove the gateway's internal correlation Id to avoid conflicts with an upstream
 			 * gateway.
 			 */
-			if (reply instanceof jakarta.jms.Message) {
-				((jakarta.jms.Message) reply).setJMSCorrelationID(null);
+			if (reply instanceof jakarta.jms.Message jmsMessage) {
+				jmsMessage.setJMSCorrelationID(null);
 			}
 			return reply;
 		}
@@ -1239,11 +1239,11 @@ private jakarta.jms.Message receiveReplyMessage(MessageConsumer messageConsumer)
 	 */
 	private void deleteDestinationIfTemporary(Destination destination) {
 		try {
-			if (destination instanceof TemporaryQueue) {
-				((TemporaryQueue) destination).delete();
+			if (destination instanceof TemporaryQueue temporaryQueue) {
+				temporaryQueue.delete();
 			}
-			else if (destination instanceof TemporaryTopic) {
-				((TemporaryTopic) destination).delete();
+			else if (destination instanceof TemporaryTopic temporaryTopic) {
+				temporaryTopic.delete();
 			}
 		}
 		catch (@SuppressWarnings("unused") JMSException e) {

spring-integration-jms/src/main/java/org/springframework/integration/jms/JmsSendingMessageHandler.java

@@ -1,5 +1,5 @@
 /*
- * Copyright 2002-2024 the original author or authors.
+ * Copyright 2002-2025 the original author or authors.
  *
  * Licensed under the Apache License, Version 2.0 (the "License");
  * you may not use this file except in compliance with the License.
@@ -212,11 +212,11 @@ private Object determineDestination(Message<?> message) {
 	}
 
 	private void send(Object destination, Object objectToSend, MessagePostProcessor messagePostProcessor) {
-		if (destination instanceof Destination) {
-			this.jmsTemplate.convertAndSend((Destination) destination, objectToSend, messagePostProcessor);
+		if (destination instanceof Destination destinationObj) {
+			this.jmsTemplate.convertAndSend(destinationObj, objectToSend, messagePostProcessor);
 		}
-		else if (destination instanceof String) {
-			this.jmsTemplate.convertAndSend((String) destination, objectToSend, messagePostProcessor);
+		else if (destination instanceof String destinationStr) {
+			this.jmsTemplate.convertAndSend(destinationStr, objectToSend, messagePostProcessor);
 		}
 		else { // fallback to default destination of the template
 			this.jmsTemplate.convertAndSend(objectToSend, messagePostProcessor);

spring-integration-jms/src/main/java/org/springframework/integration/jms/PollableJmsChannel.java

@@ -1,5 +1,5 @@
 /*
- * Copyright 2002-2024 the original author or authors.
+ * Copyright 2002-2025 the original author or authors.
  *
  * Licensed under the Apache License, Version 2.0 (the "License");
  * you may not use this file except in compliance with the License.
@@ -31,6 +31,8 @@
 import org.springframework.messaging.support.ExecutorChannelInterceptor;
 
 /**
+ * A JMS-backed channel from which messages can be received through polling.
+ *
  * @author Mark Fisher
  * @author Oleg Zhurakousky
  * @author Gary Russell
@@ -123,21 +125,13 @@ private Message<?> receiveAndConvertToMessage() {
 			}
 			return null;
 		}
-		else {
-			Message<?> message;
-			if (object instanceof Message<?>) {
-				message = (Message<?>) object;
-			}
-			else {
-				message = getMessageBuilderFactory()
-						.withPayload(object)
-						.build();
-			}
-			if (isLoggingEnabled()) {
-				logger.debug(() -> "postReceive on channel '" + this + "', message: " + message);
-			}
-			return message;
+		Message<?> message = object instanceof Message<?> msg
+				? msg
+				: getMessageBuilderFactory().withPayload(object).build();
+		if (isLoggingEnabled()) {
+			logger.debug(() -> "postReceive on channel '" + this + "', message: " + message);
 		}
+		return message;
 	}
 
 	private void incrementReceiveCounter() {