Changeset 54 for trunk/src/main/java/omq/common/broker

Timestamp:

06/21/13 12:42:25 (11 years ago)

Author:

stoda

Message:

Adding @MultiMethod?
Broker is not a singleton.

File:

• trunk/src/main/java/omq/common/broker/Broker.java (modified) (2 diffs)

trunk/src/main/java/omq/common/broker/Broker.java

@@ -176 +176 @@
                 if (responseListener == null) {
                         responseListener = new ResponseListener(this);
+                        responseListener.start();
                 }
                 if (eventDispatcher == null) {
                         eventDispatcher = new EventDispatcher(this);
+                        eventDispatcher.start();
                 }
         }
@@ -197 +199 @@
                 byte[] bytesResponse = serializer.serialize(wrapper);
                 channel.basicPublish(UID, "", null, bytesResponse);
-
-                // Log.saveLog("Server-Serialize", bytesResponse);
         }