fetch_delayed.rb in lex-tasker-0.2.0

- old
+ new

@@ -3,9 +3,19 @@
     module Queues
       class FetchDelayed < Legion::Transport::Queue
         def queue_name
           'task.fetch_delayed'
         end
+
+        def queue_options
+          {
+            arguments: {
+              'x-single-active-consumer': true,
+              'x-max-priority':           255,
+              'x-message-ttl':            1
+            }
+          }
+        end
       end
     end
   end
 end