Method: PikaQue::DelayWorker#initialize

Defined in:
lib/pika_que/delay_worker.rb

#initialize(opts = {}) ⇒ DelayWorker

Returns a new instance of DelayWorker.



6
7
8
9
10
11
 
# File 'lib/pika_que/delay_worker.rb', line 6

def initialize(opts = {})
  @opts = PikaQue.config.merge(opts)
  @broker = @opts[:broker] || PikaQue::Broker.new(nil, @opts).tap{ |b| b.start }
  @pool = @opts[:worker_pool] || Concurrent::FixedThreadPool.new(@opts[:concurrency] || 1)
  @delay_name = "#{@opts[:exchange]}-delay"
end