lib/queuel/null/queue.rb in queuel-0.0.1 vs lib/queuel/null/queue.rb in queuel-0.1.0
- old
+ new
@@ -1,20 +1,17 @@
require 'queuel/null/poller'
module Queuel
module Null
- class Queue
- def initialize(*)
+ class Queue < Base::Queue
+ def peek(options = {})
+ []
end
- # For IronMQ it should just be (message)
- def push(*)
+ def push(message)
end
- def pop(*args, &block)
- end
-
- def receive(options = {}, &block)
- Poller.new(options, block).poll
+ # Nullify
+ def pop(options = {}, &block)
end
end
end
end