class Superbolt::Runner::Base
Attributes
block[R]
error_notifier[R]
logger[R]
queue[R]
Public Class Methods
new(queue, error_notifier, logger, block)
click to toggle source
# File lib/superbolt/runner/base.rb, line 6 def initialize(queue, error_notifier, logger, block) @queue = queue @error_notifier = error_notifier @logger = logger @block = block end
Public Instance Methods
channel()
click to toggle source
# File lib/superbolt/runner/base.rb, line 13 def channel queue.channel end
on_error(message, error)
click to toggle source
# File lib/superbolt/runner/base.rb, line 17 def on_error(message, error) error_notifier.error!(error, message) end