Changeset 18 for trunk/objectmq/src/omq/common/broker/Broker.java

Timestamp:

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

Author:

gguerrero

Message:

Logs and new event.

File:

• trunk/objectmq/src/omq/common/broker/Broker.java (modified) (2 diffs)

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

@@ -7 +7 @@
 import omq.client.proxy.Proxymq;
 import omq.client.remote.response.ResponseListener;
+import omq.common.event.Event;
 import omq.common.event.EventDispatcher;
+import omq.common.event.EventWrapper;
 import omq.common.util.Environment;
 import omq.common.util.OmqConnectionFactory;
+import omq.common.util.Serializer;
 import omq.exception.EnvironmentException;
 import omq.exception.RemoteException;
+import omq.exception.SerializerException;
 import omq.server.remote.request.RemoteObject;
 
@@ -91 +95 @@
                 }
         }
+        
+        
+        public static void trigger(Event event) throws IOException, SerializerException{
+                String UID = event.getTopic();
+                EventWrapper wrapper = new EventWrapper(event);
+                channel.exchangeDeclare(UID, "fanout");
+                channel.basicPublish(UID, "", null, Serializer.serialize(wrapper));
+        }
 
 }