class ActiveMessaging::Adapters::Sqs::Message

based on stomp message, has pointer to the SQSResponseObject

Attributes

attributes[RW]
md5_of_body[RW]
queue[RW]
receipt_handle[RW]
request_id[RW]
response[RW]

Public Class Methods

from_element(e, response, queue) click to toggle source
# File lib/activemessaging/adapters/sqs.rb, line 464
def self.from_element(e, response, queue)
  attributes = {}
  e.elements.each('Attribute') { |n| attributes[n.elements['Name'].text] = n.elements['Value'].text }

  Message.new(
    e.elements['Body'].text,
    response.headers,
    e.elements['MessageId'].text,
    e.elements['MD5OfBody'].text,
    e.elements['ReceiptHandle'].text,
    attributes,
    response,
    queue)
end
new(body, headers, id, md5_of_body, receipt_handle, attributes, response, queue) click to toggle source
Calls superclass method ActiveMessaging::BaseMessage::new
# File lib/activemessaging/adapters/sqs.rb, line 479
def initialize body, headers, id, md5_of_body, receipt_handle, attributes, response, queue
  super(body, id, headers, queue.name)
  @md5_of_body, @receipt_handle, @response, @queue =  md5_of_body, receipt_handle, response, queue
end

Public Instance Methods

to_s() click to toggle source
# File lib/activemessaging/adapters/sqs.rb, line 484
def to_s
  "<AmazonSQS::Message id='#{id}' body='#{body}' headers='#{headers.inspect}' attributes='#{attributes.inspect}' response='#{response}'>"
end