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