diff --git a/helloworld/src/main/java/org/springframework/amqp/helloworld/async/ProducerConfiguration.java b/helloworld/src/main/java/org/springframework/amqp/helloworld/async/ProducerConfiguration.java index 52be209..4d3784d 100644 --- a/helloworld/src/main/java/org/springframework/amqp/helloworld/async/ProducerConfiguration.java +++ b/helloworld/src/main/java/org/springframework/amqp/helloworld/async/ProducerConfiguration.java @@ -2,7 +2,6 @@ package org.springframework.amqp.helloworld.async; import java.util.concurrent.atomic.AtomicInteger; -import org.springframework.amqp.core.Queue; import org.springframework.amqp.rabbit.config.AbstractRabbitConfiguration; import org.springframework.amqp.rabbit.connection.ConnectionFactory; import org.springframework.amqp.rabbit.connection.SingleConnectionFactory; @@ -23,7 +22,6 @@ public class ProducerConfiguration extends AbstractRabbitConfiguration { public RabbitTemplate rabbitTemplate() { RabbitTemplate template = new RabbitTemplate(connectionFactory()); template.setRoutingKey(this.helloWorldQueueName); - template.setQueue(this.helloWorldQueueName); return template; } @@ -35,11 +33,6 @@ public class ProducerConfiguration extends AbstractRabbitConfiguration { return connectionFactory; } - @Bean - public Queue helloWorldQueue() { - return new Queue(this.helloWorldQueueName); - } - @Bean public ScheduledProducer scheduledProducer() { return new ScheduledProducer();