mirror of
https://github.com/fog/fog.git
synced 2022-11-09 13:51:43 -05:00
Enable the claims_tests in mocking mode.
This commit is contained in:
parent
68b6f33767
commit
5c36c8ae08
3 changed files with 5 additions and 5 deletions
|
@ -160,7 +160,7 @@ module Fog
|
|||
|
||||
claims.keys.dup.each do |id|
|
||||
claim = claims[id]
|
||||
if claim.expired?
|
||||
if claim.expired? || claim.messages.empty?
|
||||
claim.messages.each { |m| m.claim = nil }
|
||||
claims.delete(id)
|
||||
end
|
||||
|
|
|
@ -38,7 +38,7 @@ module Fog
|
|||
|
||||
message = queue.messages.detect { |m| m.id == message_id }
|
||||
|
||||
if message.claimed?
|
||||
if message && message.claimed?
|
||||
unless message.claim.id == claim_id
|
||||
# FIXME Exception
|
||||
end
|
||||
|
@ -48,6 +48,8 @@ module Fog
|
|||
end
|
||||
end
|
||||
|
||||
queue.messages.reject! { |m| m.id == message_id }
|
||||
|
||||
response = Excon::Response.new
|
||||
response.status = 204
|
||||
response
|
||||
|
|
|
@ -1,7 +1,5 @@
|
|||
Shindo.tests('Fog::Rackspace::Queues | claims', ['rackspace']) do
|
||||
|
||||
pending if Fog.mocking?
|
||||
|
||||
service = Fog::Rackspace::Queues.new
|
||||
queue = service.queues.create({
|
||||
:name => "fog_queue_#{Time.now.to_i.to_s}",
|
||||
|
@ -16,7 +14,7 @@ Shindo.tests('Fog::Rackspace::Queues | claims', ['rackspace']) do
|
|||
}
|
||||
|
||||
begin
|
||||
collection_tests(queue.claims, params, false)
|
||||
collection_tests(queue.claims, params)
|
||||
|
||||
tests('creating claims when there are no messages') do
|
||||
|
||||
|
|
Loading…
Add table
Reference in a new issue