class Superbolt::Runner::Pop

Attributes

message[R]

Public Instance Methods

run() click to toggle source
# File lib/superbolt/runner/pop.rb, line 6
def run
  queue.subscribe(ack: false, block: true) do |delivery_info, metadata, payload|
    @message = IncomingMessage.new(delivery_info, payload, channel)
    processor = Processor.new(message, logger, &block)
    unless processor.perform
      on_error(message.parse, processor.exception) if message.parse
    end
    @message = nil
  end
end