Changeset 20 for trunk/objectmq/src/omq/common/event/EventDispatcher.java

Timestamp:

05/23/13 15:46:29 (11 years ago)

Author:

stoda

Message:

 

File:

• trunk/objectmq/src/omq/common/event/EventDispatcher.java (modified) (1 diff)

trunk/objectmq/src/omq/common/event/EventDispatcher.java

@@ -133 +133 @@
                         String queueName = env.getProperty(ParameterQueue.EVENT_REPLY_QUEUE);
                         String reference = e.getTopic();
+
+                        System.out.println("EventDispatcher declaring fanout -> " + reference + " Binding with: " + queueName);
+
                         channel.exchangeDeclare(reference, "fanout");
                         channel.queueBind(queueName, reference, "");