Changeset 54 for trunk/src/main/java/omq/common/event/EventDispatcher.java

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/event/EventDispatcher.java (modified) (3 diffs)

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

@@ -56 +56 @@
                 boolean durable = Boolean.parseBoolean(env.getProperty(ParameterQueue.DURABLE_QUEUES, "false"));
                 channel.queueDeclare(event_queue, durable, false, false, null);
+                logger.info("EventDispatcher creating queue: " + event_queue + ", durable: " + durable);
 
                 // Declare a new consumer
@@ -72 +73 @@
         @Override
         public void run() {
+                logger.info("EventDispatcher started");
                 Delivery delivery;
                 Event event;
@@ -84 +86 @@
 
                                 logger.info("Event received -> Topic: " + event.getTopic() + "CorrId: " + event.getCorrId());
-                                // Log.saveLog("Client-Deserialize", delivery.getBody());
-
-                                // long timeEnd = (new Date()).getTime();
-                                // Log.saveTimeSendRequestLog("Client-time-response",
-                                // event.getCorrId(), "Event!", timeEnd);
 
                                 // Dispatch it