to_sqs_msg

in lib/aws/active_job/sqs/lambda_handler.rb [30:45]

• 15 lines of code
• 1 McCabe index (conditional complexity)

          def to_sqs_msg(record)
            msg = Aws::SQS::Types::Message.new(
              body: record['body'],
              md5_of_body: record['md5OfBody'],
              message_attributes: 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::ActiveJob::SQS.config.client
            )
          end