self.to_sqs_msg

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