Changeset 21

Timestamp:

05/23/13 15:57:57 (11 years ago)

Author:

stoda

Message:

 

File:

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

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

@@ -95 +95 @@
                 }
         }
-        
-        
-        public static void trigger(Event event) throws IOException, SerializerException{
+
+        public static void trigger(Event event) throws IOException, SerializerException {
                 String UID = event.getTopic();
                 EventWrapper wrapper = new EventWrapper(event);
+                System.out.println("EventTrigger fanout exchange: " + UID + " Event topic: " + UID + " Event corrID: " + event.getCorrId());
                 channel.exchangeDeclare(UID, "fanout");
                 channel.basicPublish(UID, "", null, Serializer.serialize(wrapper));