Ignore:
Timestamp:
05/21/13 15:08:02 (11 years ago)
Author:
stoda
Message:

EventWrapperAdded?

File:
1 edited

Legend:

Unmodified
Added
Removed

  • trunk/objectmq/src/omq/common/event/EventDispatcher.java

    r15 r16  
    110110
    111111        public int addListener(EventListener e) throws Exception {
     112                // Map<String, ArrayList<EventListener<Event>>> mListeners =
     113                // listeners.get(e.getTopic());
     114                // if(mListeners == null){
     115                // mListeners = new HashMap<String, ArrayList<EventListener<Event>>>();
     116                //
     117                // String queueName = env.getProperty(ParameterQueue.EVENT_REPLY_QUEUE);
     118                // String reference = e.getTopic();
     119                // channel.exchangeDeclare(reference, "fanout");
     120                // channel.queueBind(queueName, reference, "");
     121                // }
     122
    112123                Vector<EventListener> vListeners = listeners.get(e.getTopic());
    113124                if (vListeners == null) {
Note: See TracChangeset for help on using the changeset viewer.