Spring/spring-amqp-samples
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Fix client to use an address, not a Queue for replyTo

Browse Source
This commit is contained in:
Dave Syer
2011-03-24 15:14:58 +00:00
parent a0074a67fb
commit 1bbc11bfb6
5 changed files with 9 additions and 13 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
stocks/src/main/java/org/springframework/amqp/rabbit/stocks/config/client/RabbitClientConfiguration.java
View File

@@ -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;
}

13
stocks/src/main/java/org/springframework/amqp/rabbit/stocks/gateway/RabbitStockServiceGateway.java
View File

@@ -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"));
}

3
stocks/src/main/resources/client-bootstrap-config.xml
View File

@@ -12,6 +12,7 @@
<import resource="classpath:client-handlers.xml" />
<import resource="classpath:client-messaging.xml" />
<!-- XML version of RabbitClientConfiguration -->
<!-- import resource="classpath:client-messaging.xml" /-->
</beans>

2
stocks/src/main/resources/client-messaging.xml
View File

@@ -6,7 +6,7 @@
<bean id="stockServiceGateway" class="org.springframework.amqp.rabbit.stocks.gateway.RabbitStockServiceGateway">
<property name="rabbitTemplate" ref="rabbitTemplate" />
<property name="defaultReplyToQueue" value="#{traderJoeQueue.name}" />
<property name="defaultReplyTo" value="#{traderJoeQueue.name}" />
</bean>
<listener-container concurrency="5" connection-factory="connectionFactory" message-converter="jsonMessageConverter"

2
stocks/src/main/resources/servlet-config.xml
View File

@@ -15,7 +15,7 @@
<property name="messageConverter" ref="jsonMessageConverter" />
</bean>
</property>
<property name="defaultReplyToQueue" ref="tradeQueue" />
<property name="defaultReplyTo" value="fanout://broadcast.responses/" />
</bean>
<rabbit:queue id="tradeQueue" />