Changeset 28

Timestamp:

05/29/13 11:40:05 (12 years ago)

Author:

stoda

Message:

 

Location:

trunk/objectmq

Files:

• src/omq/common/event/EventDispatcher.java (modified) (1 diff)
• test/test2 (added)
• test/test2/Car.java (added)
• test/test2/CarImpl.java (added)
• test/test2/Rim.java (added)

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

@@ -164 +164 @@
          */
         public void dispatch(String topic, final Event event) {
-                for (final EventListener listener : listeners.get(topic)) {
-                        new Thread() {
-                                public void run() {
-                                        listener.notifyEvent(event);
-                                }
-                        }.start();
+                if (listeners.containsKey(topic)) {
+                        for (final EventListener listener : listeners.get(topic)) {
+                                new Thread() {
+                                        public void run() {
+                                                listener.notifyEvent(event);
+                                        }
+                                }.start();
+                        }
                 }
         }