class RPCBench::Server
Public Class Methods
new(opts)
click to toggle source
# File lib/rpc_bench/server.rb, line 3 def initialize(opts) case opts[:mode] when 'rabbitmq' @driver = RabbitMQ::Server.new opts when 'grpc' @driver = GRPC::Server.new opts when 'zeromq' @driver = ZeroMQ::Server.new opts when 'stomp' @driver = Stomp::Server.new opts else raise RuntimeError.new("failed to initialize driver of '#{opts[:mode]}'") end @driver.set_handler self end
Public Instance Methods
callback(v)
click to toggle source
# File lib/rpc_bench/server.rb, line 24 def callback(v) v.to_i + 1 end
run()
click to toggle source
# File lib/rpc_bench/server.rb, line 20 def run @driver.run end