diff --git a/stocks/src/main/java/org/springframework/amqp/rabbit/stocks/config/client/RabbitClientConfiguration.java b/stocks/src/main/java/org/springframework/amqp/rabbit/stocks/config/client/RabbitClientConfiguration.java
index 0d73576..7ad8b28 100644
--- a/stocks/src/main/java/org/springframework/amqp/rabbit/stocks/config/client/RabbitClientConfiguration.java
+++ b/stocks/src/main/java/org/springframework/amqp/rabbit/stocks/config/client/RabbitClientConfiguration.java
@@ -70,7 +70,7 @@ public class RabbitClientConfiguration extends AbstractStockAppRabbitConfigurati
public StockServiceGateway stockServiceGateway() {
RabbitStockServiceGateway gateway = new RabbitStockServiceGateway();
gateway.setRabbitTemplate(rabbitTemplate());
- gateway.setDefaultReplyToQueue(traderJoeQueue());
+ gateway.setDefaultReplyTo(traderJoeQueue().getName());
return gateway;
}
diff --git a/stocks/src/main/java/org/springframework/amqp/rabbit/stocks/gateway/RabbitStockServiceGateway.java b/stocks/src/main/java/org/springframework/amqp/rabbit/stocks/gateway/RabbitStockServiceGateway.java
index 6ac673a..5b5058a 100644
--- a/stocks/src/main/java/org/springframework/amqp/rabbit/stocks/gateway/RabbitStockServiceGateway.java
+++ b/stocks/src/main/java/org/springframework/amqp/rabbit/stocks/gateway/RabbitStockServiceGateway.java
@@ -23,7 +23,6 @@ import org.springframework.amqp.AmqpException;
import org.springframework.amqp.core.Address;
import org.springframework.amqp.core.Message;
import org.springframework.amqp.core.MessagePostProcessor;
-import org.springframework.amqp.core.Queue;
import org.springframework.amqp.rabbit.core.support.RabbitGatewaySupport;
import org.springframework.amqp.rabbit.stocks.domain.TradeRequest;
@@ -34,20 +33,16 @@ import org.springframework.amqp.rabbit.stocks.domain.TradeRequest;
*/
public class RabbitStockServiceGateway extends RabbitGatewaySupport implements StockServiceGateway {
- private String defaultReplyToQueue;
+ private String defaultReplyTo;
- public void setDefaultReplyToQueue(String defaultReplyToQueue) {
- this.defaultReplyToQueue = defaultReplyToQueue;
+ public void setDefaultReplyTo(String defaultReplyTo) {
+ this.defaultReplyTo = defaultReplyTo;
}
- public void setDefaultReplyToQueue(Queue defaultReplyToQueue) {
- this.defaultReplyToQueue = defaultReplyToQueue.getName();
- }
-
public void send(TradeRequest tradeRequest) {
getRabbitTemplate().convertAndSend(tradeRequest, new MessagePostProcessor() {
public Message postProcessMessage(Message message) throws AmqpException {
- message.getMessageProperties().setReplyTo(new Address(defaultReplyToQueue));
+ message.getMessageProperties().setReplyTo(new Address(defaultReplyTo));
try {
message.getMessageProperties().setCorrelationId(UUID.randomUUID().toString().getBytes("UTF-8"));
}
diff --git a/stocks/src/main/resources/client-bootstrap-config.xml b/stocks/src/main/resources/client-bootstrap-config.xml
index c8926db..bce686d 100644
--- a/stocks/src/main/resources/client-bootstrap-config.xml
+++ b/stocks/src/main/resources/client-bootstrap-config.xml
@@ -12,6 +12,7 @@
-
+
+
diff --git a/stocks/src/main/resources/client-messaging.xml b/stocks/src/main/resources/client-messaging.xml
index effad33..2e7bbd2 100644
--- a/stocks/src/main/resources/client-messaging.xml
+++ b/stocks/src/main/resources/client-messaging.xml
@@ -6,7 +6,7 @@
-
+
-
+