class EventBus::Broker::Base

Public Class Methods

close_connection() click to toggle source
# File lib/event_bus/broker/base.rb, line 14
def self.close_connection
  raise NotImplementedError.new('Must be implemented')
end
consume(event_name, &block) click to toggle source
# File lib/event_bus/broker/base.rb, line 18
def self.consume(event_name, &block)
  consumers[event_name] ||= begin
    new.consume(event_name, &block)
  end
end
consumers() click to toggle source
# File lib/event_bus/broker/base.rb, line 6
def self.consumers
  @consumers ||= {}
end
produce(events) click to toggle source
# File lib/event_bus/broker/base.rb, line 28
def self.produce(events)
  new.produce(events)
end

Public Instance Methods

connection() click to toggle source
# File lib/event_bus/broker/base.rb, line 10
def connection
  raise NotImplementedError.new('Must be implemented')
end
consume(event_name, &block) click to toggle source
# File lib/event_bus/broker/base.rb, line 24
def consume(event_name, &block)
  raise NotImplementedError.new('Must be implemented')
end
produce(events) click to toggle source
# File lib/event_bus/broker/base.rb, line 32
def produce(events)
  raise NotImplementedError.new('Must be implemented')
end