Method: Circuitry::Subscriber#initialize

Defined in:
lib/circuitry/subscriber.rb

#initialize(options = {}) ⇒ Subscriber

Returns a new instance of Subscriber.



29
30
31
32
33
34
35
36
37
38
39
40
 
# File 'lib/circuitry/subscriber.rb', line 29

def initialize(options = {})
  options = DEFAULT_OPTIONS.merge(options)

  self.subscribed = false
  self.queue = Queue.find(Circuitry.subscriber_config.queue_name).url

  %i[lock async timeout wait_time batch_size].each do |sym|
    send(:"#{sym}=", options[sym])
  end

  trap_signals
end