class Msgr::Dispatcher
The Dispatcher
receives incoming messages, process them through a middleware stack and delegate them to a new and fresh consumer instance.
Attributes
config[R]
pool[R]
Public Class Methods
new(config)
click to toggle source
# File lib/msgr/dispatcher.rb, line 13 def initialize(config) config[:pool_class] ||= 'Msgr::Dispatcher::NullPool' log(:debug) do "Initialize new dispatcher (#{config[:pool_class]}: #{config})..." end @config = config @pool = config[:pool_class].constantize.new config end
Public Instance Methods
call(message)
click to toggle source
# File lib/msgr/dispatcher.rb, line 24 def call(message) pool.post(message) do |msg| dispatch msg end end
dispatch(message)
click to toggle source
# File lib/msgr/dispatcher.rb, line 30 def dispatch(message) consumer_class = Object.const_get message.route.consumer log(:debug) { "Dispatch message to #{consumer_class.name}" } consumer_class.new.dispatch message # Acknowledge message only if it is not already acknowledged and auto # acknowledgment is enabled. message.ack unless message.acked? || !consumer_class.auto_ack? rescue StandardError => e message.nack unless message.acked? log(:error) do "Dispatcher error: #{e.class.name}: #{e}\n" + e.backtrace.join("\n") end raise e if config[:raise_exceptions] ensure if defined?(ActiveRecord) && ActiveRecord::Base.connection_pool.active_connection? log(:debug) { 'Release used AR connection for dispatcher thread.' } ActiveRecord::Base.connection_pool.release_connection end end
shutdown()
click to toggle source
# File lib/msgr/dispatcher.rb, line 57 def shutdown; end
to_s()
click to toggle source
# File lib/msgr/dispatcher.rb, line 59 def to_s self.class.name end