Sha256: 1f25d0a8f74f95a03b39fa9008ff94522a08159ccc494e3212d6f826bdbad247
Contents?: true
Size: 1.26 KB
Versions: 8
Compression:
Stored size: 1.26 KB
Contents
require 'qs/qs_runner'
module Qs
class Route
attr_reader :id, :handler_class_name, :handler_class
def initialize(route_id, handler_class_name)
@id = route_id.to_s
@handler_class_name = handler_class_name
@handler_class = nil
end
def validate!
@handler_class = constantize_handler_class(@handler_class_name)
end
def run(message, daemon_data)
QsRunner.new(self.handler_class, {
:message => message,
:params => message.params,
:logger => daemon_data.logger
}).run
end
private
def constantize_handler_class(handler_class_name)
constantize(handler_class_name).tap do |handler_class|
raise(NoHandlerClassError.new(handler_class_name)) if !handler_class
end
end
def constantize(class_name)
names = class_name.to_s.split('::').reject{ |name| name.empty? }
klass = names.inject(Object){ |constant, name| constant.const_get(name) }
klass == Object ? false : klass
rescue NameError
false
end
end
class NoHandlerClassError < RuntimeError
def initialize(handler_class_name)
super "Qs couldn't find the handler '#{handler_class_name}'" \
" - it doesn't exist or hasn't been required in yet."
end
end
end
Version data entries
8 entries across 8 versions & 1 rubygems