Changeset 50 for trunk/src/main/java/omq/common/broker/Broker.java

Timestamp:

06/19/13 16:06:31 (11 years ago)

Author:

stoda

Message:

 

File:

• trunk/src/main/java/omq/common/broker/Broker.java (modified) (1 diff)

trunk/src/main/java/omq/common/broker/Broker.java

@@ -202 +202 @@
                 String UID = event.getTopic();
                 EventWrapper wrapper = new EventWrapper(event);
-                System.out.println("EventTrigger fanout exchange: " + UID + " Event topic: " + UID + " Event corrID: " + event.getCorrId());
+                logger.debug("EventTrigger fanout exchange: " + UID + " Event topic: " + UID + " Event corrID: " + event.getCorrId());
                 channel.exchangeDeclare(UID, "fanout");