Sha256: 7b0e7a1b94a47dbe47a3dac9a984db273cc31eea44400dfea7b5296a6f793eb1
Contents?: true
Size: 1.12 KB
Versions: 19
Compression:
Stored size: 1.12 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
#
# Dispatch the given message to the given object.
#
def self.message( engine, msg, to_obj, params = nil )
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
19 entries across 19 versions & 1 rubygems