Contents

module EventBus
  module Listeners
    class Base
      attr_reader :channel

      def initialize(channel)
        @channel = channel
      end

      def self.bind(method, event_name)
        Manager.register_listener_configuration({
          listener_class: self,
          method: method,
          routing_key: event_name
        })
      end
    end
  end
end

Version data entries

5 entries across 5 versions & 1 rubygems

Version	Path
event_bus_rb-2.1.0	lib/event_bus/listeners/base.rb
event_bus_rb-2.0.3	lib/event_bus/listeners/base.rb
event_bus_rb-2.0.2	lib/event_bus/listeners/base.rb
event_bus_rb-2.0.1	lib/event_bus/listeners/base.rb
event_bus_rb-2.0.0	lib/event_bus/listeners/base.rb