Sha256: 6724828b0fc2498a2f775dfa96e2653344ebc4411086a5e4bb4d7b5e97014bd4

Contents?: true

Size: 1.73 KB

Versions: 11

Compression:

Stored size: 1.73 KB

Contents

module Fog
  module AWS
    class SQS
      class Real

        require 'fog/aws/parsers/sqs/basic'

        # Delete a message from a queue
        #
        # ==== Parameters
        # * queue_url<~String> - Url of queue to delete message from
        # * receipt_handle<~String> - Token from previous recieve message
        #
        # ==== See Also
        # http://docs.amazonwebservices.com/AWSSimpleQueueService/latest/APIReference/Query_QueryDeleteMessage.html
        #

        def delete_message(queue_url, receipt_handle)
          request({
            'Action'        => 'DeleteMessage',
            'ReceiptHandle' => receipt_handle,
            :parser         => Fog::Parsers::AWS::SQS::Basic.new,
            :path           => path_from_queue_url(queue_url),
          })
        end

      end
      
      class Mock

        def delete_message(queue_url, receipt_handle)
          Excon::Response.new.tap do |response|
            if (queue = data[:queues][queue_url])
              message_id, _ = queue[:receipt_handles].find { |msg_id, receipts|
                receipts.keys.include?(receipt_handle)
              }

              if message_id
                queue[:receipt_handles].delete(message_id)
                queue[:messages].delete(message_id)
                queue['Attributes']['LastModifiedTimestamp'] = Time.now
              end

              response.body = {
                'ResponseMetadata' => {
                  'RequestId' => Fog::AWS::Mock.request_id
                }
              }
              response.status = 200
            else
              response.status = 404
              raise(Excon::Errors.status_error({:expects => 200}, response))
            end
          end
        end

      end
    end
  end
end

Version data entries

11 entries across 11 versions & 4 rubygems

Version Path
brightbox-cli-0.17.1 lib/brightbox-cli/vendor/fog/lib/fog/aws/requests/sqs/delete_message.rb
brightbox-cli-0.17.0 lib/brightbox-cli/vendor/fog/lib/fog/aws/requests/sqs/delete_message.rb
fog-1.1.2 lib/fog/aws/requests/sqs/delete_message.rb
fog_tractical-1.1.4 lib/fog/aws/requests/sqs/delete_message.rb
fog_tractical-1.1.3 lib/fog/aws/requests/sqs/delete_message.rb
brightbox-cli-0.16.0 lib/brightbox-cli/vendor/fog/lib/fog/aws/requests/sqs/delete_message.rb
fog-1.1.1 lib/fog/aws/requests/sqs/delete_message.rb
fog-1.1.0 lib/fog/aws/requests/sqs/delete_message.rb
brightbox-cli-0.15.0 lib/brightbox-cli/vendor/fog/lib/fog/aws/requests/sqs/delete_message.rb
tag-fog-1.0.1 lib/fog/aws/requests/sqs/delete_message.rb
fog-1.0.0 lib/fog/aws/requests/sqs/delete_message.rb