in lib/aws/rails/sqs_active_job/lambda_handler.rb [27:42]
def self.to_sqs_msg(record)
msg = Aws::SQS::Types::Message.new(
body: record['body'],
md5_of_body: record['md5OfBody'],
message_attributes: self.to_message_attributes(record),
message_id: record['messageId'],
receipt_handle: record['receiptHandle']
)
Aws::SQS::Message.new(
queue_url: to_queue_url(record),
receipt_handle: msg.receipt_handle,
data: msg,
client: Aws::Rails::SqsActiveJob.config.client
)
end