class MessageDriver::Adapters::Base

Attributes

broker[R]

Public Class Methods

new(_broker, _configuration) click to toggle source
# File lib/message_driver/adapters/base.rb, line 12
def initialize(_broker, _configuration)
  raise 'Must be implemented in subclass'
end

Public Instance Methods

build_context() click to toggle source
# File lib/message_driver/adapters/base.rb, line 22
def build_context
  raise 'Must be implemented in subclass'
end
contexts() click to toggle source
# File lib/message_driver/adapters/base.rb, line 8
def contexts
  @contexts ||= []
end
new_context() click to toggle source
# File lib/message_driver/adapters/base.rb, line 16
def new_context
  ctx = build_context
  contexts << ctx
  ctx
end
reset_after_tests() click to toggle source
# File lib/message_driver/adapters/base.rb, line 26
def reset_after_tests
  # does nothing, can be overridden by adapters that want to support testing scenarios
end
stop() click to toggle source
# File lib/message_driver/adapters/base.rb, line 30
def stop
  if @contexts
    ctxs = @contexts
    @contexts = []
    ctxs.each(&:invalidate)
  end
end