diff --git a/spring-integration-jms/src/main/java/org/springframework/integration/jms/JmsOutboundGateway.java b/spring-integration-jms/src/main/java/org/springframework/integration/jms/JmsOutboundGateway.java index fbb651444e..f96f0cbf15 100644 --- a/spring-integration-jms/src/main/java/org/springframework/integration/jms/JmsOutboundGateway.java +++ b/spring-integration-jms/src/main/java/org/springframework/integration/jms/JmsOutboundGateway.java @@ -600,6 +600,10 @@ public class JmsOutboundGateway extends AbstractReplyProducingMessageHandler imp if (StringUtils.hasText(this.replyDestinationName)) { container.setDestinationName(this.replyDestinationName); } + else { + // to be resolved to the TemporaryQueue + container.setDestinationName(""); + } if (this.destinationResolver != null) { container.setDestinationResolver(this.destinationResolver); } @@ -1399,7 +1403,7 @@ public class JmsOutboundGateway extends AbstractReplyProducingMessageHandler imp @Override protected String getDestinationDescription() { if (this.replyDestination instanceof TemporaryQueue) { - return "Temporary queue:" + this.replyDestination.toString(); + return "Temporary queue: " + this.replyDestination.toString(); } else if (super.getDestination() != null) { try { diff --git a/spring-integration-jmx/src/test/java/org/springframework/integration/jmx/config/ControlBusParserTests.java b/spring-integration-jmx/src/test/java/org/springframework/integration/jmx/config/ControlBusParserTests.java index ea8cbbc3bc..e245e69469 100644 --- a/spring-integration-jmx/src/test/java/org/springframework/integration/jmx/config/ControlBusParserTests.java +++ b/spring-integration-jmx/src/test/java/org/springframework/integration/jmx/config/ControlBusParserTests.java @@ -1,5 +1,5 @@ /* - * Copyright 2002-2016 the original author or authors. + * Copyright 2002-2017 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. @@ -27,16 +27,16 @@ import org.springframework.integration.core.MessagingTemplate; import org.springframework.jmx.export.MBeanExporter; import org.springframework.messaging.MessageChannel; import org.springframework.test.annotation.DirtiesContext; -import org.springframework.test.context.ContextConfiguration; -import org.springframework.test.context.junit4.SpringJUnit4ClassRunner; +import org.springframework.test.context.junit4.SpringRunner; /** * @author Mark Fisher * @author Gary Russell + * @author Artem Bilan + * * @since 2.0 */ -@ContextConfiguration -@RunWith(SpringJUnit4ClassRunner.class) +@RunWith(SpringRunner.class) @DirtiesContext public class ControlBusParserTests { @@ -48,7 +48,7 @@ public class ControlBusParserTests { MessageChannel control = this.context.getBean("controlChannel", MessageChannel.class); MessagingTemplate messagingTemplate = new MessagingTemplate(); Object value = messagingTemplate.convertSendAndReceive(control, - "@integrationMbeanExporter.getChannelSendRate('testChannel').count", null); + "@integrationMbeanExporter.getChannelSendRate('testChannel').count", Object.class); assertEquals(0, value); MBeanExporter exporter = this.context.getBean(MBeanExporter.class); exporter.destroy();