Class: StagedEvent::SubscriberProcess

Inherits:

Object

• Object
• StagedEvent::SubscriberProcess

Includes:

Technologic

Defined in:

lib/staged_event/subscriber_process.rb

Instance Method Summary

• #initialize(subscriber) ⇒ SubscriberProcess constructor

  A new instance of SubscriberProcess.

• #run ⇒ Object

Constructor Details

#initialize(subscriber) ⇒ SubscriberProcess

Returns a new instance of SubscriberProcess.

# File 'lib/staged_event/subscriber_process.rb', line 7

def initialize(subscriber)
  @subscriber = subscriber
end

Instance Method Details

#run ⇒ Object

# File 'lib/staged_event/subscriber_process.rb', line 11

def run
  subscriber.receive_events
rescue StandardError => exception
  error :subscriber_main_loop_failed, exception: exception.message
  retry
rescue SignalException => exception
  error :signal_exception, message: exception.message
end