From bbfab5f8d88dec6ca7a540ac67d9530fb5615c50 Mon Sep 17 00:00:00 2001 From: markpollack Date: Wed, 7 Jul 2010 20:09:28 -0400 Subject: [PATCH] AMQP-6 Implement AmqpAdmin interface with RabbitAdmin implementation --- .../springframework/amqp/helloworld/RabbitConfiguration.java | 2 +- .../stocks/config/AbstractStockAppRabbitConfiguration.java | 2 +- .../stocks/config/client/RabbitClientConfiguration.java | 4 ++-- 3 files changed, 4 insertions(+), 4 deletions(-) diff --git a/helloworld/src/main/java/org/springframework/amqp/helloworld/RabbitConfiguration.java b/helloworld/src/main/java/org/springframework/amqp/helloworld/RabbitConfiguration.java index 1db595f..38e5b52 100644 --- a/helloworld/src/main/java/org/springframework/amqp/helloworld/RabbitConfiguration.java +++ b/helloworld/src/main/java/org/springframework/amqp/helloworld/RabbitConfiguration.java @@ -3,7 +3,7 @@ package org.springframework.amqp.helloworld; import javax.annotation.PostConstruct; import org.springframework.amqp.core.Queue; -import org.springframework.amqp.rabbit.admin.config.AbstractRabbitConfiguration; +import org.springframework.amqp.rabbit.config.AbstractRabbitConfiguration; import org.springframework.amqp.rabbit.connection.CachingConnectionFactory; import org.springframework.amqp.rabbit.connection.ConnectionFactory; import org.springframework.amqp.rabbit.core.RabbitTemplate; diff --git a/stocks/src/main/java/org/springframework/amqp/rabbit/stocks/config/AbstractStockAppRabbitConfiguration.java b/stocks/src/main/java/org/springframework/amqp/rabbit/stocks/config/AbstractStockAppRabbitConfiguration.java index ab6fcd6..e49b077 100644 --- a/stocks/src/main/java/org/springframework/amqp/rabbit/stocks/config/AbstractStockAppRabbitConfiguration.java +++ b/stocks/src/main/java/org/springframework/amqp/rabbit/stocks/config/AbstractStockAppRabbitConfiguration.java @@ -17,7 +17,7 @@ package org.springframework.amqp.rabbit.stocks.config; import org.springframework.amqp.core.TopicExchange; -import org.springframework.amqp.rabbit.admin.config.AbstractRabbitConfiguration; +import org.springframework.amqp.rabbit.config.AbstractRabbitConfiguration; import org.springframework.amqp.rabbit.connection.CachingConnectionFactory; import org.springframework.amqp.rabbit.connection.ConnectionFactory; import org.springframework.amqp.rabbit.core.RabbitTemplate; 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 d281f98..66ef941 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 @@ -109,7 +109,7 @@ public class RabbitClientConfiguration extends AbstractStockAppRabbitConfigurati @Bean public Queue marketDataQueue() { - return declareQueue(); + return randomNameQueueDefinition(); } /** @@ -129,7 +129,7 @@ public class RabbitClientConfiguration extends AbstractStockAppRabbitConfigurati */ @Bean public Queue traderJoeQueue() { - return declareQueue(); + return randomNameQueueDefinition(); }