RAYO-122 : Allow apps to skip Moho's default behaviour

rayo · Sep 19, 2013 · 2f5aa9a · 2f5aa9a
1 parent 0fa7ae2
commit 2f5aa9a
Showing 1 changed file with 6 additions and 4 deletions.
diff --git a/rayo-server/src/main/java/com/rayo/server/ActorEventListener.java b/rayo-server/src/main/java/com/rayo/server/ActorEventListener.java
@@ -1,8 +1,7 @@
 package com.rayo.server;
 
-import java.util.concurrent.TimeUnit;
-
 import com.voxeo.moho.common.util.SettableResultFuture;
+import com.voxeo.moho.event.AcceptableEvent;
 import com.voxeo.moho.event.Event;
 import com.voxeo.moho.event.EventSource;
 import com.voxeo.moho.utils.EventListener;
@@ -27,7 +26,10 @@ public void handle(Response response) throws Exception {
 
         actor.publish(request);
 
-        future.get(30, TimeUnit.SECONDS);
-
+        if (event instanceof AcceptableEvent) {
+            // MOHO-83 : Skip contention by setting async on moho level
+        	((AcceptableEvent)event).setAsync(true);        	
+        }
     }
 }
+