class Shoryuken::Message

Attributes

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

Public Class Methods

new(client, queue, data) click to toggle source
# File lib/shoryuken/message.rb, line 16
def initialize(client, queue, data)
  self.client     = client
  self.data       = data
  self.queue_url  = queue.url
  self.queue_name = queue.name
end

Public Instance Methods

change_visibility(options) click to toggle source
# File lib/shoryuken/message.rb, line 30
def change_visibility(options)
  client.change_message_visibility(
    options.merge(queue_url: queue_url, receipt_handle: data.receipt_handle)
  )
end
delete() click to toggle source
# File lib/shoryuken/message.rb, line 23
def delete
  client.delete_message(
    queue_url: queue_url,
    receipt_handle: data.receipt_handle
  )
end
visibility_timeout=(timeout) click to toggle source
# File lib/shoryuken/message.rb, line 36
def visibility_timeout=(timeout)
  client.change_message_visibility(
    queue_url: queue_url,
    receipt_handle: data.receipt_handle,
    visibility_timeout: timeout
  )
end