2013-07-19 21:38:31 -04:00
|
|
|
Shindo.tests('Fog::Rackspace::Queues | claim', ['rackspace']) do
|
|
|
|
|
|
|
|
pending if Fog.mocking?
|
|
|
|
|
2013-10-10 10:25:35 -05:00
|
|
|
service = Fog::Rackspace::Queues.new
|
2013-07-19 21:38:31 -04:00
|
|
|
queue = service.queues.create({
|
|
|
|
:name => "fog_queue_#{Time.now.to_i.to_s}",
|
|
|
|
})
|
|
|
|
queue.messages.create({
|
|
|
|
:ttl => VALID_TTL,
|
|
|
|
:body => { :random => :body }
|
|
|
|
})
|
|
|
|
|
|
|
|
params = {
|
|
|
|
:ttl => VALID_TTL,
|
|
|
|
:grace => VALID_GRACE
|
|
|
|
}
|
|
|
|
|
|
|
|
begin
|
|
|
|
model_tests(queue.claims, params, false) do
|
|
|
|
tests('#messages') do
|
|
|
|
returns(1) { @instance.messages.length }
|
|
|
|
returns('body') { @instance.messages.first.body['random'] }
|
|
|
|
end
|
|
|
|
|
|
|
|
tests('#update').succeeds do
|
|
|
|
@instance.ttl = VALID_TTL + 5
|
|
|
|
@instance.save
|
|
|
|
end
|
|
|
|
end
|
|
|
|
|
|
|
|
queue.messages.create({
|
|
|
|
:ttl => VALID_TTL,
|
|
|
|
:body => { :random => :body }
|
|
|
|
})
|
|
|
|
tests('destroying claimed messages').succeeds do
|
|
|
|
claim = queue.claims.create(params)
|
|
|
|
claim.messages.first.destroy
|
|
|
|
end
|
|
|
|
ensure
|
|
|
|
queue.destroy
|
|
|
|
end
|
|
|
|
end
|