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