lib/octave/agent.rb
# Loop to pass the payload to each dispatcher as the payload enters the
# queue.
Loop to pass the payload to each dispatcher as the payload enters the
queue.
Loop to pass the payload to each dispatcher as the payload enters the queue .
def run
      while running? || !queue.empty?
        payload = queue.pop(false)
        call_dispatchers(payload)
      end
    end
def run while running? || ! queue . empty? payload = queue . pop ( false ) call_dispatchers ( payload ) end end
Loop to pass the payload to each dispatcher as the payload enters the
queue.
Loop to pass the payload to each dispatcher as the payload enters the queue .