Contents

module ActionSubscriber
  module Subscriber
    # resubscribes to queue, continuously retrying to subscribe in the event of a potentially recoverable error while
    # also calling the error handler to surface that a subscription failure happened
    def safely_restart_subscriber(subscription)
      subscription[:queue] = setup_queue(subscription[:route])
      start_subscriber_for_subscription(subscription)
    rescue StandardError => e
      ::ActionSubscriber.configuration.error_handler.call(e)
      raise e unless e.message =~ /queue .* process is stopped by supervisor/

      nap_time = rand(2.0..5.0)
      ::ActionSubscriber.logger.error("Failed to resubscribe to #{subscription[:queue].name}, retrying again in #{nap_time} seconds...")
      sleep(nap_time)
      retry
    end
  end
end

Version data entries

14 entries across 14 versions & 1 rubygems

Version	Path
action_subscriber-5.3.3-java	lib/action_subscriber/subscriber.rb
action_subscriber-5.3.3	lib/action_subscriber/subscriber.rb
action_subscriber-5.3.2-java	lib/action_subscriber/subscriber.rb
action_subscriber-5.3.2	lib/action_subscriber/subscriber.rb
action_subscriber-5.3.1-java	lib/action_subscriber/subscriber.rb
action_subscriber-5.3.1	lib/action_subscriber/subscriber.rb
action_subscriber-5.3.1.pre-java	lib/action_subscriber/subscriber.rb
action_subscriber-5.3.1.pre	lib/action_subscriber/subscriber.rb
action_subscriber-5.3.0-java	lib/action_subscriber/subscriber.rb
action_subscriber-5.3.0	lib/action_subscriber/subscriber.rb
action_subscriber-5.2.4-java	lib/action_subscriber/subscriber.rb
action_subscriber-5.2.4	lib/action_subscriber/subscriber.rb
action_subscriber-5.2.3-java	lib/action_subscriber/subscriber.rb
action_subscriber-5.2.3	lib/action_subscriber/subscriber.rb