Ignore:
Timestamp:
06/27/13 11:44:54 (11 years ago)
Author:
stoda
Message:

EventTest? added

File:
1 edited

Legend:

Unmodified
Added
Removed
  • trunk/src/main/java/omq/server/RemoteObject.java

    r66 r67  
    9393                this.broker = broker;
    9494                UID = reference;
     95                serializer = broker.getSerializer();
    9596                if (channel == null || !channel.isOpen()) {
    9697                        channel = broker.getChannel();
     
    142143        @Override
    143144        public void notifyEvent(Event event) throws IOException, SerializerException {
     145                String corrID = java.util.UUID.randomUUID().toString();
    144146                event.setTopic(UID);
     147                event.setCorrId(corrID);
    145148                EventWrapper wrapper = new EventWrapper(event);
    146149                channel.exchangeDeclare(UID, "fanout");
    147150                channel.basicPublish(UID, "", null, serializer.serialize(wrapper));
     151                logger.debug("Sending event-> topic: " + UID + ", corrID: " + corrID);
    148152        }
    149153
Note: See TracChangeset for help on using the changeset viewer.