Sha256: 15ec85d0560f292df2c675617883c40beeb624b0cb6d28622f8a6a5b23e457fa
Contents?: true
Size: 1.62 KB
Versions: 79
Compression:
Stored size: 1.62 KB
Contents
Shindo.tests('AWS::SQS | message requests', ['aws']) do
tests('success') do
@queue_url = Fog::AWS[:sqs].create_queue('fog_message_tests').body['QueueUrl']
send_message_format = AWS::SQS::Formats::BASIC.merge({
'MessageId' => String,
'MD5OfMessageBody' => String
})
tests("#send_message('#{@queue_url}', 'message')").formats(send_message_format) do
Fog::AWS[:sqs].send_message(@queue_url, 'message').body
end
receive_message_format = AWS::SQS::Formats::BASIC.merge({
'Message' => [{
'Attributes' => {
'ApproximateFirstReceiveTimestamp' => Time,
'ApproximateReceiveCount' => Integer,
'SenderId' => String,
'SentTimestamp' => Time
},
'Body' => String,
'MD5OfBody' => String,
'MessageId' => String,
'ReceiptHandle' => String
}]
})
tests("#receive_message").formats(receive_message_format) do
data = Fog::AWS[:sqs].receive_message(@queue_url).body
@receipt_handle = data['Message'].first['ReceiptHandle']
data
end
tests("#change_message_visibility('#{@queue_url}, '#{@receipt_handle}', 60)").formats(AWS::SQS::Formats::BASIC) do
Fog::AWS[:sqs].change_message_visibility(@queue_url, @receipt_handle, 60).body
end
tests("#delete_message('#{@queue_url}', '#{@receipt_handle}')").formats(AWS::SQS::Formats::BASIC) do
Fog::AWS[:sqs].delete_message(@queue_url, @receipt_handle).body
end
unless Fog.mocking?
Fog::AWS[:sqs].delete_queue(@queue_url)
end
end
end
Version data entries
79 entries across 77 versions & 6 rubygems