Changeset 21 for trunk


Ignore:
Timestamp:
05/23/13 15:57:57 (11 years ago)
Author:
stoda
Message:
 
File:
1 edited

Legend:

Unmodified
Added
Removed
  • trunk/objectmq/src/omq/common/broker/Broker.java

    r18 r21  
    9595                }
    9696        }
    97        
    98        
    99         public static void trigger(Event event) throws IOException, SerializerException{
     97
     98        public static void trigger(Event event) throws IOException, SerializerException {
    10099                String UID = event.getTopic();
    101100                EventWrapper wrapper = new EventWrapper(event);
     101                System.out.println("EventTrigger fanout exchange: " + UID + " Event topic: " + UID + " Event corrID: " + event.getCorrId());
    102102                channel.exchangeDeclare(UID, "fanout");
    103103                channel.basicPublish(UID, "", null, Serializer.serialize(wrapper));
Note: See TracChangeset for help on using the changeset viewer.