class DispatchRider::Dispatcher

Attributes

handler_registrar[R]

Public Class Methods

new() click to toggle source
# File lib/dispatch-rider/dispatcher.rb, line 18
def initialize
  @handler_registrar = Registrars::Handler.new
end

Public Instance Methods

dispatch(message) click to toggle source
# File lib/dispatch-rider/dispatcher.rb, line 22
def dispatch(message)
  callbacks.invoke(:dispatch_message, message) do
    handler_registrar.fetch(message.subject).new.do_process(message)
  end
  true # success => true (delete message)
end