Changeset 54 for trunk/src/main/java/omq/client/listener/ResponseListener.java

Timestamp:

06/21/13 12:42:25 (11 years ago)

Author:

stoda

Message:

Adding @MultiMethod?
Broker is not a singleton.

File:

• trunk/src/main/java/omq/client/listener/ResponseListener.java (modified) (2 diffs)

trunk/src/main/java/omq/client/listener/ResponseListener.java

@@ -55 +55 @@
         @Override
         public void run() {
+                logger.info("ResponseListener started");
                 Delivery delivery;
                 String uid_request;
@@ -122 +123 @@
 
                 channel.queueDeclare(reply_queue, durable, false, false, args);
+                logger.info("ResponseListener creating queue: " + reply_queue + ", durable: " + durable);
 
                 // Declare a new consumer