diff --git a/spring-rabbit/src/test/java/org/springframework/amqp/rabbit/core/PojoHandler.java b/spring-rabbit-admin/src/test/java/org/springframework/amqp/rabbit/admin/PojoHandler.java similarity index 88% rename from spring-rabbit/src/test/java/org/springframework/amqp/rabbit/core/PojoHandler.java rename to spring-rabbit-admin/src/test/java/org/springframework/amqp/rabbit/admin/PojoHandler.java index 77641ea5..77a692ed 100644 --- a/spring-rabbit/src/test/java/org/springframework/amqp/rabbit/core/PojoHandler.java +++ b/spring-rabbit-admin/src/test/java/org/springframework/amqp/rabbit/admin/PojoHandler.java @@ -1,15 +1,14 @@ -package org.springframework.amqp.rabbit.core; +package org.springframework.amqp.rabbit.admin; import java.util.concurrent.atomic.AtomicInteger; public class PojoHandler { private final AtomicInteger messageCount = new AtomicInteger(); - public void handleMessage(String textMessage) { int msgCount = this.messageCount.incrementAndGet(); System.out.println("Thread [" + Thread.currentThread().getId() + "] PojoHandler Received Message " + msgCount + ", = " + textMessage); - } + } diff --git a/spring-rabbit-admin/src/test/java/org/springframework/amqp/rabbit/admin/RabbitConsumerConfiguration.java b/spring-rabbit-admin/src/test/java/org/springframework/amqp/rabbit/admin/RabbitConsumerConfiguration.java index 3fe2c7c1..cf829d05 100644 --- a/spring-rabbit-admin/src/test/java/org/springframework/amqp/rabbit/admin/RabbitConsumerConfiguration.java +++ b/spring-rabbit-admin/src/test/java/org/springframework/amqp/rabbit/admin/RabbitConsumerConfiguration.java @@ -1,6 +1,5 @@ package org.springframework.amqp.rabbit.admin; -import org.springframework.amqp.rabbit.core.PojoHandler; import org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer; import org.springframework.amqp.rabbit.listener.adapter.MessageListenerAdapter; import org.springframework.context.annotation.Bean; @@ -15,11 +14,10 @@ public class RabbitConsumerConfiguration extends TestRabbitConfiguration { container.setConnectionFactory(connectionFactory()); container.setQueueName(TestConstants.QUEUE_NAME); container.setConcurrentConsumers(5); - MessageListenerAdapter adapter = new MessageListenerAdapter(); adapter.setDelegate(new PojoHandler()); container.setMessageListener(adapter); - return container; } + }