class Barbeque::MessageHandler::Notification

Public Class Methods

new(message:, message_queue:) click to toggle source

@param [Barbeque::Message::Notification] message @param [Barbeque::MessageQueue] message_queue

# File lib/barbeque/message_handler/notification.rb, line 8
def initialize(message:, message_queue:)
  @message = message
  @message_queue = message_queue

  subscription = SNSSubscription.find_by!(topic_arn: @message.topic_arn, job_queue_id: @message_queue.job_queue.id)
  @message.set_params_from_subscription(subscription)
end