class Circuitry::Message

Attributes

sqs_message[R]

Public Class Methods

new(sqs_message) click to toggle source
# File lib/circuitry/message.rb, line 8
def initialize(sqs_message)
  @sqs_message = sqs_message
end

Public Instance Methods

body() click to toggle source
# File lib/circuitry/message.rb, line 16
def body
  @body ||= JSON.parse(context['Message'], quirks_mode: true)
end
context() click to toggle source
# File lib/circuitry/message.rb, line 12
def context
  @context ||= JSON.parse(sqs_message.body)
end
id() click to toggle source
# File lib/circuitry/message.rb, line 24
def id
  sqs_message.message_id
end
receipt_handle() click to toggle source
# File lib/circuitry/message.rb, line 28
def receipt_handle
  sqs_message.receipt_handle
end
topic() click to toggle source
# File lib/circuitry/message.rb, line 20
def topic
  @topic ||= Topic.new(context['TopicArn'])
end