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