class Toiler::Aws::Message

SQS Message abstraction Provides methods for querying and acting on a SQS message

Attributes

client[RW]
data[RW]
queue_url[RW]

Public Class Methods

new(client, queue_url, data) click to toggle source
# File lib/toiler/aws/message.rb, line 8
def initialize(client, queue_url, data)
  @client = client
  @queue_url = queue_url
  @data = data
end

Public Instance Methods

attributes() click to toggle source
# File lib/toiler/aws/message.rb, line 51
def attributes
  data.attributes
end
body() click to toggle source
# File lib/toiler/aws/message.rb, line 47
def body
  data.body
end
change_visibility(options) click to toggle source
# File lib/toiler/aws/message.rb, line 21
def change_visibility(options)
  client.change_message_visibility(
    options.merge(queue_url: queue_url, receipt_handle: receipt_handle)
  )
end
delete() click to toggle source
# File lib/toiler/aws/message.rb, line 14
def delete
  client.delete_message(
    queue_url: queue_url,
    receipt_handle: data.receipt_handle
  )
end
md5_of_body() click to toggle source
# File lib/toiler/aws/message.rb, line 43
def md5_of_body
  data.md5_of_body
end
md5_of_message_attributes() click to toggle source
# File lib/toiler/aws/message.rb, line 55
def md5_of_message_attributes
  data.md5_of_message_attributes
end
message_attributes() click to toggle source
# File lib/toiler/aws/message.rb, line 59
def message_attributes
  data.message_attributes
end
message_id() click to toggle source
# File lib/toiler/aws/message.rb, line 35
def message_id
  data.message_id
end
receipt_handle() click to toggle source
# File lib/toiler/aws/message.rb, line 39
def receipt_handle
  data.receipt_handle
end
visibility_timeout=(timeout) click to toggle source
# File lib/toiler/aws/message.rb, line 27
def visibility_timeout=(timeout)
  client.change_message_visibility(
    queue_url: queue_url,
    receipt_handle: data.receipt_handle,
    visibility_timeout: timeout
  )
end