Module: Sequent::Core::Helpers::MessageHandler::ClassMethods
- Defined in:
- lib/sequent/core/helpers/message_handler.rb
Instance Method Summary collapse
- #handles_message?(message) ⇒ Boolean
- #message_mapping ⇒ Object
- #message_router ⇒ Object
- #on(*args, **opts, &block) ⇒ Object
- #option(name, &block) ⇒ Object
Instance Method Details
#handles_message?(message) ⇒ Boolean
70 71 72 |
# File 'lib/sequent/core/helpers/message_handler.rb', line 70 def () .() end |
#message_mapping ⇒ Object
62 63 64 65 66 67 68 |
# File 'lib/sequent/core/helpers/message_handler.rb', line 62 def .routes .select { |matcher, _handlers| matcher.is_a?(MessageMatchers::InstanceOf) } .map { |k, v| [k.expected_class, v] } .to_h end |
#message_router ⇒ Object
74 75 76 |
# File 'lib/sequent/core/helpers/message_handler.rb', line 74 def @message_router ||= MessageRouter.new end |
#on(*args, **opts, &block) ⇒ Object
43 44 45 46 47 48 49 50 51 52 53 54 55 56 |
# File 'lib/sequent/core/helpers/message_handler.rb', line 43 def on(*args, **opts, &block) OnArgumentsValidator.validate_arguments!(*args) = args.map { |arg| MessageMatchers::ArgumentCoercer.coerce_argument(arg) } .register_matchers( *, block, ) opts.each do |name, value| option_registry.call_option(self, name, , value) end end |
#option(name, &block) ⇒ Object
58 59 60 |
# File 'lib/sequent/core/helpers/message_handler.rb', line 58 def option(name, &block) option_registry.register_option(name, block) end |