Contents

module Shoryuken
  class Message
    attr_accessor :client, :queue_url, :data

    def initialize(client, queue_url, data)
      self.client = client
      self.queue_url = queue_url
      self.data = data
    end

    def delete
      client.delete_message(
        queue_url: queue_url,
        receipt_handle: data.receipt_handle
      )
    end

    def change_visibility(options)
      client.change_message_visibility(
        options.merge(queue_url: queue_url, receipt_handle: data.receipt_handle)
      )
    end

    def visibility_timeout=(timeout)
      client.change_message_visibility(
        queue_url: queue_url,
        receipt_handle: data.receipt_handle,
        visibility_timeout: timeout
      )
    end

    def message_id
      data.message_id
    end

    def receipt_handle
      data.receipt_handle
    end

    def md5_of_body
      data.md5_of_body
    end

    def body
      data.body
    end

    def attributes
      data.attributes
    end

    def md5_of_message_attributes
      data.md5_of_message_attributes
    end

    def message_attributes
      data.message_attributes
    end
  end
end

Version data entries

3 entries across 3 versions & 1 rubygems

Version	Path
shoryuken-1.0.3	lib/shoryuken/message.rb
shoryuken-1.0.2	lib/shoryuken/message.rb
shoryuken-1.0.1	lib/shoryuken/message.rb