Index: trunk/objectmq/src/omq/common/broker/Broker.java
===================================================================
--- trunk/objectmq/src/omq/common/broker/Broker.java	(revision 20)
+++ trunk/objectmq/src/omq/common/broker/Broker.java	(revision 21)
@@ -95,9 +95,9 @@
 		}
 	}
-	
-	
-	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));