Sha256: 03ce33712fd99f26c165a3c13ccc02dddb45196ef2d4bbce28d63ae16340f7d4

Contents?: true

Size: 1.7 KB

Versions: 9

Compression:

Stored size: 1.7 KB

Contents

# Author::    Eric Crane  (mailto:eric.crane@mac.com)
# Copyright:: Copyright (c) 2020 Eric Crane.  All rights reserved.
#
# Central Message Dispatch.
# Responsible for sending message to objects.
# All object messaging goes through here so we can uniformly
# manage things like checking to make sure object can
# receive the messages sent, handling errors, etc.
#

module Gloo
  module Exec
    class Dispatch

      OBJ_NOT_FOUND_ERR = 'Object was not found: '.freeze

      # 
      # Send a message to an object of a given name (and path).
      # Once the object is found, the message is dispatched.
      # 
      def self.send_message( engine, msg, to_obj_pn, params = nil )
        pn = Gloo::Core::Pn.new( engine, to_obj_pn )
        target_obj = pn.resolve

        unless target_obj
          engine.err "#{OBJ_NOT_FOUND_ERR} #{to_obj_pn}"
          return
        end
        Gloo::Exec::Dispatch.message( engine, msg, target_obj, params )
      end

      #
      # Dispatch the given message to the given object.
      #
      def self.message( engine, msg, to_obj, params = nil )
        return unless to_obj
        
        engine.log.debug "Dispatch message #{msg} to #{to_obj.name}"
        a = Gloo::Exec::Action.new msg, to_obj, params
        Gloo::Exec::Dispatch.action( engine, a )
      end

      #
      # Dispatch an action.
      #
      def self.action( engine, action )
        unless action.valid?
          engine.log.warn "Object #{action.to.name} does not respond to #{action.msg}"
        end

        engine.exec_env.push_action action
        engine.log.debug "Sending message #{action.msg} to #{action.to.name}"
        action.dispatch
        engine.exec_env.pop_action
      end

    end
  end
end

Version data entries

9 entries across 9 versions & 1 rubygems

Version Path
gloo-3.10.1 lib/gloo/exec/dispatch.rb
gloo-3.10.0 lib/gloo/exec/dispatch.rb
gloo-3.9.1 lib/gloo/exec/dispatch.rb
gloo-3.9.0 lib/gloo/exec/dispatch.rb
gloo-3.8.0 lib/gloo/exec/dispatch.rb
gloo-3.7.0 lib/gloo/exec/dispatch.rb
gloo-3.6.2 lib/gloo/exec/dispatch.rb
gloo-3.6.1 lib/gloo/exec/dispatch.rb
gloo-3.6.0 lib/gloo/exec/dispatch.rb