diff --git a/spring-jms/src/main/java/org/springframework/jms/core/JmsMessageOperations.java b/spring-jms/src/main/java/org/springframework/jms/core/JmsMessageOperations.java index fa706b4642f..d08f9f13a0f 100644 --- a/spring-jms/src/main/java/org/springframework/jms/core/JmsMessageOperations.java +++ b/spring-jms/src/main/java/org/springframework/jms/core/JmsMessageOperations.java @@ -27,8 +27,8 @@ import org.springframework.messaging.core.MessageReceivingOperations; import org.springframework.messaging.core.MessageSendingOperations; /** - * A specialization of {@link MessageSendingOperations} and {@link MessageSendingOperations} - * for JMS related operations that allows to specify a destination name rather than the + * A specialization of {@link MessageSendingOperations} and {@link MessageReceivingOperations} + * for JMS related operations that allow to specify a destination name rather than the * actual {@link javax.jms.Destination} * * @author Stephane Nicoll diff --git a/spring-jms/src/main/java/org/springframework/jms/core/support/JmsGatewaySupport.java b/spring-jms/src/main/java/org/springframework/jms/core/support/JmsGatewaySupport.java index 8f0f7c94c24..9a54c30a111 100644 --- a/spring-jms/src/main/java/org/springframework/jms/core/support/JmsGatewaySupport.java +++ b/spring-jms/src/main/java/org/springframework/jms/core/support/JmsGatewaySupport.java @@ -53,7 +53,6 @@ public abstract class JmsGatewaySupport implements InitializingBean { * Will automatically create a JmsTemplate for the given ConnectionFactory. * @see #createJmsTemplate * @see #setConnectionFactory(javax.jms.ConnectionFactory) - * @param connectionFactory */ public final void setConnectionFactory(ConnectionFactory connectionFactory) { this.jmsTemplate = createJmsTemplate(connectionFactory); @@ -81,7 +80,6 @@ public abstract class JmsGatewaySupport implements InitializingBean { /** * Set the JmsTemplate for the gateway. - * @param jmsTemplate * @see #setConnectionFactory(javax.jms.ConnectionFactory) */ public final void setJmsTemplate(JmsTemplate jmsTemplate) { diff --git a/spring-jms/src/test/java/org/springframework/jms/config/MethodJmsListenerEndpointTests.java b/spring-jms/src/test/java/org/springframework/jms/config/MethodJmsListenerEndpointTests.java index ef554117547..e4525361e82 100644 --- a/spring-jms/src/test/java/org/springframework/jms/config/MethodJmsListenerEndpointTests.java +++ b/spring-jms/src/test/java/org/springframework/jms/config/MethodJmsListenerEndpointTests.java @@ -137,6 +137,17 @@ public class MethodJmsListenerEndpointTests { assertDefaultListenerMethodInvocation(); } + @Test + public void resolveCustomHeaderNameAndPayload() throws JMSException { + MessagingMessageListenerAdapter listener = createDefaultInstance(String.class, int.class); + + Session session = mock(Session.class); + StubTextMessage message = createSimpleJmsTextMessage("my payload"); + message.setIntProperty("myCounter", 24); + listener.onMessage(message, session); + assertDefaultListenerMethodInvocation(); + } + @Test public void resolveHeaders() throws JMSException { MessagingMessageListenerAdapter listener = createDefaultInstance(String.class, Map.class); @@ -426,10 +437,16 @@ public class MethodJmsListenerEndpointTests { assertEquals("Wrong message payload", "test", message.getPayload()); } - public void resolveHeaderAndPayload(@Payload String content, @Header("myCounter") int counter) { + public void resolveHeaderAndPayload(@Payload String content, @Header int myCounter) { invocations.put("resolveHeaderAndPayload", true); assertEquals("Wrong @Payload resolution", "my payload", content); - assertEquals("Wrong @Header resolution", 55, counter); + assertEquals("Wrong @Header resolution", 55, myCounter); + } + + public void resolveCustomHeaderNameAndPayload(@Payload String content, @Header("myCounter") int counter) { + invocations.put("resolveCustomHeaderNameAndPayload", true); + assertEquals("Wrong @Payload resolution", "my payload", content); + assertEquals("Wrong @Header resolution", 24, counter); } public void resolveHeaders(String content, @Headers Map headers) {