Apply DestinationResolver to listener container

Previously, a custom `DestinationResolver` was not made available
to the underlying `MessageListener`: if a reply needs to be sent, the
default `DestinationResolver` was used.

This commit ensures that if a custom `DestinationResolver` has been set,
it is also configured accordingly for replies.

Issue: SPR-12927

Author: snicoll

spring-jms/src/main/java/org/springframework/jms/config/MethodJmsListenerEndpoint.java

@@ -25,6 +25,7 @@
 import org.springframework.jms.listener.MessageListenerContainer;
 import org.springframework.jms.listener.adapter.MessagingMessageListenerAdapter;
 import org.springframework.jms.support.converter.MessageConverter;
+import org.springframework.jms.support.destination.DestinationResolver;
 import org.springframework.messaging.handler.annotation.SendTo;
 import org.springframework.messaging.handler.annotation.support.MessageHandlerMethodFactory;
 import org.springframework.messaging.handler.invocation.InvocableHandlerMethod;
@@ -100,6 +101,10 @@ protected MessagingMessageListenerAdapter createMessageListener(MessageListenerC
 		if (messageConverter != null) {
 			messageListener.setMessageConverter(messageConverter);
 		}
+		DestinationResolver destinationResolver = container.getDestinationResolver();
+		if (destinationResolver != null) {
+			messageListener.setDestinationResolver(destinationResolver);
+		}
 		return messageListener;
 	}
 

spring-jms/src/main/java/org/springframework/jms/listener/MessageListenerContainer.java

@@ -18,6 +18,7 @@
 
 import org.springframework.context.SmartLifecycle;
 import org.springframework.jms.support.converter.MessageConverter;
+import org.springframework.jms.support.destination.DestinationResolver;
 
 /**
  * Internal abstraction used by the framework representing a message
@@ -41,6 +42,12 @@ public interface MessageListenerContainer extends SmartLifecycle {
 	 */
 	MessageConverter getMessageConverter();
 
+	/**
+	 * Return the {@link DestinationResolver} to use to resolve
+	 * destinations by names.
+	 */
+	DestinationResolver getDestinationResolver();
+
 	/**
 	 * Return whether the Publish/Subscribe domain ({@link javax.jms.Topic Topics}) is used.
 	 * Otherwise, the Point-to-Point domain ({@link javax.jms.Queue Queues}) is used.

spring-jms/src/main/java/org/springframework/jms/listener/endpoint/JmsMessageEndpointManager.java

@@ -191,6 +191,14 @@ public MessageConverter getMessageConverter() {
 		return null;
 	}
 
+	@Override
+	public DestinationResolver getDestinationResolver() {
+		if (this.activationSpecFactory instanceof StandardJmsActivationSpecFactory) {
+			return ((StandardJmsActivationSpecFactory) this.activationSpecFactory).getDestinationResolver();
+		}
+		return null;
+	}
+
 	@Override
 	public boolean isPubSubDomain() {
 		JmsActivationSpecConfig config = getActivationSpecConfig();

spring-jms/src/main/java/org/springframework/jms/listener/endpoint/StandardJmsActivationSpecFactory.java

@@ -1,5 +1,5 @@
 /*
- * Copyright 2002-2014 the original author or authors.
+ * Copyright 2002-2015 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.
@@ -90,6 +90,12 @@ public void setDestinationResolver(DestinationResolver destinationResolver) {
 		this.destinationResolver = destinationResolver;
 	}
 
+	/**
+	 * Return the {@link DestinationResolver} to use for resolving destinations names.
+	 */
+	public DestinationResolver getDestinationResolver() {
+		return destinationResolver;
+	}
 
 	@Override
 	public ActivationSpec createActivationSpec(ResourceAdapter adapter, JmsActivationSpecConfig config) {

spring-jms/src/test/java/org/springframework/jms/config/JmsListenerContainerFactoryTests.java

@@ -182,6 +182,7 @@ private void setDefaultJcaConfig(DefaultJcaListenerContainerFactory factory) {
 
 	private void assertDefaultJcaConfig(JmsMessageEndpointManager container) {
 		assertEquals(messageConverter, container.getMessageConverter());
+		assertEquals(destinationResolver, container.getDestinationResolver());
 		JmsActivationSpecConfig config = container.getActivationSpecConfig();
 		assertNotNull(config);
 		assertEquals(Session.DUPS_OK_ACKNOWLEDGE, config.getAcknowledgeMode());

spring-jms/src/test/java/org/springframework/jms/config/MessageListenerTestContainer.java

@@ -21,6 +21,7 @@
 import org.springframework.jms.JmsException;
 import org.springframework.jms.listener.MessageListenerContainer;
 import org.springframework.jms.support.converter.MessageConverter;
+import org.springframework.jms.support.destination.DestinationResolver;
 
 /**
  * @author Stephane Nicoll
@@ -103,6 +104,11 @@ public MessageConverter getMessageConverter() {
 		return null;
 	}
 
+	@Override
+	public DestinationResolver getDestinationResolver() {
+		return null;
+	}
+
 	@Override
 	public boolean isPubSubDomain() {
 		return true;

spring-jms/src/test/java/org/springframework/jms/config/MethodJmsListenerEndpointTests.java

@@ -36,6 +36,7 @@
 import org.junit.rules.ExpectedException;
 import org.junit.rules.TestName;
 
+import org.springframework.beans.DirectFieldAccessor;
 import org.springframework.beans.factory.support.StaticListableBeanFactory;
 import org.springframework.jms.StubTextMessage;
 import org.springframework.jms.listener.DefaultMessageListenerContainer;
@@ -46,6 +47,7 @@
 import org.springframework.jms.listener.adapter.ReplyFailureException;
 import org.springframework.jms.support.JmsHeaders;
 import org.springframework.jms.support.JmsMessageHeaderAccessor;
+import org.springframework.jms.support.converter.MessageConverter;
 import org.springframework.jms.support.destination.DestinationResolver;
 import org.springframework.messaging.Message;
 import org.springframework.messaging.MessageHeaders;
@@ -107,6 +109,20 @@ public void createMessageListener() {
 		assertNotNull(endpoint.createMessageListener(container));
 	}
 
+	@Test
+	public void setExtraCollaborators() {
+		MessageConverter messageConverter = mock(MessageConverter.class);
+		DestinationResolver destinationResolver = mock(DestinationResolver.class);
+		this.container.setMessageConverter(messageConverter);
+		this.container.setDestinationResolver(destinationResolver);
+
+		MessagingMessageListenerAdapter listener = createInstance(this.factory,
+				getListenerMethod("resolveObjectPayload", MyBean.class), container);
+		DirectFieldAccessor accessor = new DirectFieldAccessor(listener);
+		assertSame(messageConverter, accessor.getPropertyValue("messageConverter"));
+		assertSame(destinationResolver, accessor.getPropertyValue("destinationResolver"));
+	}
+
 	@Test
 	public void resolveMessageAndSession() throws JMSException {
 		MessagingMessageListenerAdapter listener = createDefaultInstance(javax.jms.Message.class, Session.class);

spring-jms/src/test/java/org/springframework/jms/listener/endpoint/JmsMessageEndpointManagerTests.java

@@ -61,4 +61,10 @@ public void getMessageConverterNoConfig() {
 		JmsMessageEndpointManager endpoint = new JmsMessageEndpointManager();
 		assertNull(endpoint.getMessageConverter());
 	}
+
+	@Test
+	public void getDestinationResolverNoConfig() {
+		JmsMessageEndpointManager endpoint = new JmsMessageEndpointManager();
+		assertNull(endpoint.getDestinationResolver());
+	}
 }