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