[rackspace] Queues: makes block optional when dequeuing
This commit is contained in:
parent
69be1910f2
commit
4644e5eb1b
|
@ -91,7 +91,7 @@ module Fog
|
|||
|
||||
if claim
|
||||
message = claim.messages.first
|
||||
yield message
|
||||
yield message if block_given?
|
||||
message.destroy
|
||||
true
|
||||
else
|
||||
|
|
|
@ -24,5 +24,14 @@ Shindo.tests('Fog::Rackspace::Queues | queue', ['rackspace']) do
|
|||
@instance.dequeue(60, 60) do |message|
|
||||
end
|
||||
end
|
||||
|
||||
tests('#dequeue(60, 60) => not passing block').returns(true) do
|
||||
@instance.enqueue("msg", 60)
|
||||
@instance.dequeue(60, 60)
|
||||
end
|
||||
|
||||
tests('#dequeue(60, 60) => with not messages and not passing block').returns(false) do
|
||||
@instance.dequeue(60, 60)
|
||||
end
|
||||
end
|
||||
end
|
||||
|
|
Loading…
Reference in New Issue