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