Support a "direct" priority to run jobs synchronously.

j0hnds · Jun 3, 2008 · 6a6674f · 6a6674f
1 parent 169b62d
commit 6a6674f
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/lib/async_observer/queue.rb b/lib/async_observer/queue.rb
@@ -47,7 +47,7 @@ def sync_run(obj)
 
   def put!(obj, pri=DEFAULT_PRI, delay=DEFAULT_DELAY, ttr=DEFAULT_TTR,
            tube=DEFAULT_TUBE)
-    return sync_run(obj) if !queue
+    return sync_run(obj) if (:direct.equal?(pri) or !queue)
     queue.connect()
     queue.use(tube)
     info = [queue.yput(obj, pri, delay, ttr), queue.last_server]