svn commit: r1507882 - /synapse/trunk/java/modules/transports/optional/amqp/src/test/java/org/apache/synapse/tranport/amqp/AMQPConsumerClient.java

[rajikak]

Author: rajikak
Date: Mon Jul 29 02:03:06 2013
New Revision: 1507882

URL: http://svn.apache.org/r1507882
Log:
fixed the rabbitmq client.

Modified:
    
synapse/trunk/java/modules/transports/optional/amqp/src/test/java/org/apache/synapse/tranport/amqp/AMQPConsumerClient.java

Modified: 
synapse/trunk/java/modules/transports/optional/amqp/src/test/java/org/apache/synapse/tranport/amqp/AMQPConsumerClient.java
URL: 
http://svn.apache.org/viewvc/synapse/trunk/java/modules/transports/optional/amqp/src/test/java/org/apache/synapse/tranport/amqp/AMQPConsumerClient.java?rev=1507882&r1=1507881&r2=1507882&view=diff
==============================================================================
--- 
synapse/trunk/java/modules/transports/optional/amqp/src/test/java/org/apache/synapse/tranport/amqp/AMQPConsumerClient.java
 (original)
+++ 
synapse/trunk/java/modules/transports/optional/amqp/src/test/java/org/apache/synapse/tranport/amqp/AMQPConsumerClient.java
 Mon Jul 29 02:03:06 2013
@@ -27,8 +27,10 @@ public class AMQPConsumerClient {
         channel.basicConsume(QUEUE_NAME, true, consumer);
         System.out.println("Waiting for message on queue '" + QUEUE_NAME + 
"'");
 
-        QueueingConsumer.Delivery delivery = consumer.nextDelivery();
-        String message = new String(delivery.getBody());
-        System.out.println("[x] received '" + message + "'");
+        while (true) {
+            QueueingConsumer.Delivery delivery = consumer.nextDelivery();
+            String message = new String(delivery.getBody());
+            System.out.println("[x] received '" + message + "'");
+        }
     }
 }