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