Changeset 67 for trunk/src/main/java/omq

Timestamp:

06/27/13 11:44:54 (11 years ago)

Author:

stoda

Message:

EventTest? added

File:

• trunk/src/main/java/omq/server/RemoteObject.java (modified) (2 diffs)

trunk/src/main/java/omq/server/RemoteObject.java

@@ -93 +93 @@
                 this.broker = broker;
                 UID = reference;
+                serializer = broker.getSerializer();
                 if (channel == null || !channel.isOpen()) {
                         channel = broker.getChannel();
@@ -142 +143 @@
         @Override
         public void notifyEvent(Event event) throws IOException, SerializerException {
+                String corrID = java.util.UUID.randomUUID().toString();
                 event.setTopic(UID);
+                event.setCorrId(corrID);
                 EventWrapper wrapper = new EventWrapper(event);
                 channel.exchangeDeclare(UID, "fanout");
                 channel.basicPublish(UID, "", null, serializer.serialize(wrapper));
+                logger.debug("Sending event-> topic: " + UID + ", corrID: " + corrID);
         }