class ClusteredRpc::Transport::LocalProcess
Public Instance Methods
get_result(request_id)
click to toggle source
# File lib/clustered_rpc/transport/local_process.rb, line 11 def get_result(request_id) Thread.current[:clustered_pass_through_result] end
method_missing(method, *args)
click to toggle source
# File lib/clustered_rpc/transport/local_process.rb, line 15 def method_missing(method, *args) raise "LocalProcess cluster attempted to call missing method [#{method}]. Do you have missing Redis configuration?" end
publish(payload={})
click to toggle source
# File lib/clustered_rpc/transport/local_process.rb, line 6 def publish(payload={}) result = run_method_from_message(payload) Thread.current[:clustered_pass_through_result] = { ClusteredRpc.instance_id => result.to_json} end