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