lib/pigeon/queue.rb
# Adds a processor to the queue and adds an observer claim method.
Adds a processor to the queue and adds an observer claim method.
Adds a processor to the queue and adds an observer claim method .
def add_processor(processor, &claim)
    @observers.synchronize do
      @processors << processor
    end
    observe(&claim) if (claim)
  end
def add_processor ( processor , & claim ) @observers . synchronize do @processors << processor end observe ( & claim ) if ( claim ) end
Adds a processor to the queue and adds an observer claim method.
Adds a processor to the queue and adds an observer claim method .
processor
claim