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

Use RabbitAdmin to defer queue declaration

Browse Source
This commit is contained in:
Dave Syer
2011-08-09 14:42:14 +01:00
parent df9847b30f
commit c1d0b77444
1 changed files with 12 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -17,9 +17,13 @@
package org.springframework.amqp.rabbit.stocks.config.client;
import org.springframework.amqp.core.AcknowledgeMode;
import org.springframework.amqp.core.AmqpAdmin;
import org.springframework.amqp.core.AnonymousQueue;
import org.springframework.amqp.core.Binding;
import org.springframework.amqp.core.BindingBuilder;
import org.springframework.amqp.core.Queue;
import org.springframework.amqp.rabbit.core.RabbitAdmin;
import org.springframework.amqp.rabbit.core.RabbitTemplate;
import org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer;
import org.springframework.amqp.rabbit.listener.adapter.MessageListenerAdapter;
@@ -72,6 +76,7 @@ public class RabbitClientConfiguration extends AbstractStockAppRabbitConfigurati
SimpleMessageListenerContainer container = new SimpleMessageListenerContainer(connectionFactory());
container.setQueues(marketDataQueue(), traderJoeQueue());
container.setMessageListener(messageListenerAdapter());
container.setAcknowledgeMode(AcknowledgeMode.AUTO);
return container;
//container(using(connectionFactory()).listenToQueues(marketDataQueue(), traderJoeQueue()).withListener(messageListenerAdapter()).
@@ -97,7 +102,7 @@ public class RabbitClientConfiguration extends AbstractStockAppRabbitConfigurati
@Bean
public Queue marketDataQueue() {
return amqpAdmin().declareQueue();
return new AnonymousQueue();
}
/**
@@ -113,7 +118,12 @@ public class RabbitClientConfiguration extends AbstractStockAppRabbitConfigurati
*/
@Bean
public Queue traderJoeQueue() {
return amqpAdmin().declareQueue();
return new AnonymousQueue();
}
@Bean
public AmqpAdmin rabbitAdmin() {
return new RabbitAdmin(connectionFactory());
}
}