Class: Superbolt::Runner::Base
- Inherits:
-
Object
- Object
- Superbolt::Runner::Base
- Defined in:
- lib/superbolt/runner/base.rb
Instance Attribute Summary collapse
-
#block ⇒ Object
readonly
Returns the value of attribute block.
-
#error_notifier ⇒ Object
readonly
Returns the value of attribute error_notifier.
-
#logger ⇒ Object
readonly
Returns the value of attribute logger.
-
#queue ⇒ Object
readonly
Returns the value of attribute queue.
Instance Method Summary collapse
- #channel ⇒ Object
-
#initialize(queue, error_notifier, logger, block) ⇒ Base
constructor
A new instance of Base.
- #on_error(message, error) ⇒ Object
Constructor Details
#initialize(queue, error_notifier, logger, block) ⇒ Base
Returns a new instance of Base.
6 7 8 9 10 11 |
# 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 |
Instance Attribute Details
#block ⇒ Object (readonly)
Returns the value of attribute block.
4 5 6 |
# File 'lib/superbolt/runner/base.rb', line 4 def block @block end |
#error_notifier ⇒ Object (readonly)
Returns the value of attribute error_notifier.
4 5 6 |
# File 'lib/superbolt/runner/base.rb', line 4 def error_notifier @error_notifier end |
#logger ⇒ Object (readonly)
Returns the value of attribute logger.
4 5 6 |
# File 'lib/superbolt/runner/base.rb', line 4 def logger @logger end |
#queue ⇒ Object (readonly)
Returns the value of attribute queue.
4 5 6 |
# File 'lib/superbolt/runner/base.rb', line 4 def queue @queue end |
Instance Method Details
#channel ⇒ Object
13 14 15 |
# File 'lib/superbolt/runner/base.rb', line 13 def channel queue.channel end |
#on_error(message, error) ⇒ Object
17 18 19 |
# File 'lib/superbolt/runner/base.rb', line 17 def on_error(, error) error_notifier.error!(error, ) end |