Browse Source

polishing

pull/602/head
Stephane Nicoll 12 years ago
parent
commit
0a46f38527
  1. 4
      spring-jms/src/main/java/org/springframework/jms/core/JmsMessageOperations.java
  2. 2
      spring-jms/src/main/java/org/springframework/jms/core/support/JmsGatewaySupport.java
  3. 21
      spring-jms/src/test/java/org/springframework/jms/config/MethodJmsListenerEndpointTests.java

4
spring-jms/src/main/java/org/springframework/jms/core/JmsMessageOperations.java

@ -27,8 +27,8 @@ import org.springframework.messaging.core.MessageReceivingOperations; @@ -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

2
spring-jms/src/main/java/org/springframework/jms/core/support/JmsGatewaySupport.java

@ -53,7 +53,6 @@ public abstract class JmsGatewaySupport implements InitializingBean { @@ -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 { @@ -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) {

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

@ -137,6 +137,17 @@ public class MethodJmsListenerEndpointTests { @@ -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 { @@ -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<String, Object> headers) {

Loading…
Cancel
Save