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

moved the PojoHandler class into the spring-rabbit-admin project since that's where it's used

Browse Source
This commit is contained in:
Mark Fisher
2010-07-02 18:14:09 -04:00
parent 4a2461ca99
commit 4645a9b6cc
2 changed files with 3 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
spring-rabbit/src/test/java/org/springframework/amqp/rabbit/core/PojoHandler.java → spring-rabbit-admin/src/test/java/org/springframework/amqp/rabbit/admin/PojoHandler.java
View File

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

4
spring-rabbit-admin/src/test/java/org/springframework/amqp/rabbit/admin/RabbitConsumerConfiguration.java
View File

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