Module: Isono::Runner::RpcServer

Defined in:

lib/isono/runner/rpc_server.rb

Overview

Run a new agent which provides RPC endpoint and delayed job.

class RpcEndpoint1 def func1 end end

class RpcEndpoint2 def func2 end end

Isono::Runner::RpcServer.start do endpoint('xxxx1', RpcEndpoint1.new) endpoint('xxxx2', RpcEndpoint2.new) end

mc = MessagingClient.new xxxx1 = mc.rpc('xxxx1') xxxx1.func1

xxxx2 = mc.rpc('xxxx2') xxxx2.func2

Defined Under Namespace

Classes: EndpointBuilder, Server

Constant Summary

DEFAULT_MANIFEST =

Manifest.new(Dir.pwd) do
  load_module NodeModules::EventChannel
  load_module NodeModules::DirectChannel
  load_module NodeModules::RpcChannel
  load_module NodeModules::JobWorker
  load_module NodeModules::JobChannel
end

Class Method Summary

• .start(manifest = nil, opts = {}, &blk) ⇒ Object

Class Method Details

.start(manifest = nil, opts = {}, &blk) ⇒ Object

# File 'lib/isono/runner/rpc_server.rb', line 168

def start(manifest=nil, opts={}, &blk)
  rpcsvr = Server.new(blk)
  rpcsvr.run(manifest)
end