Changeset 35 for trunk/objectmq/src/omq/common/event/EventDispatcher.java

Timestamp:

06/11/13 12:42:38 (11 years ago)

Author:

stoda

Message:

 

File:

• trunk/objectmq/src/omq/common/event/EventDispatcher.java (modified) (4 diffs)

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

@@ -24 +24 @@
  * 
  */
+@SuppressWarnings("rawtypes")
 public class EventDispatcher extends Thread {
         private static EventDispatcher dispatcher;
@@ -43 +44 @@
 
                 String event_queue = env.getProperty(ParameterQueue.EVENT_REPLY_QUEUE);
-                channel.queueDeclare(event_queue, false, false, false, null);
+                boolean durable = Boolean.parseBoolean(env.getProperty(ParameterQueue.DURABLE_QUEUES, "false"));
+                channel.queueDeclare(event_queue, durable, false, false, null);
 
                 // Declare a new consumer
@@ -96 +98 @@
 
                                 System.out.println("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);
-                                
+                                // Log.saveLog("Client-Deserialize", delivery.getBody());
+
+                                // long timeEnd = (new Date()).getTime();
+                                // Log.saveTimeSendRequestLog("Client-time-response",
+                                // event.getCorrId(), "Event!", timeEnd);
+
                                 // Dispatch it
                                 dispatch(event.getTopic(), event);
@@ -171 +174 @@
                         for (final EventListener listener : listeners.get(topic)) {
                                 new Thread() {
+                                        @SuppressWarnings("unchecked")
                                         public void run() {
                                                 listener.notifyEvent(event);