class Protobuf::Rpc::Zmq::Server

def start_broker
  @broker = Thread.new(self) do |server|
    ::Protobuf::Rpc::Zmq::Broker.new(server).run
  end
end