class Protobuf::Rpc::Zmq::Broker

def process_backend
  worker, ignore, *frames = read_from_backend
  @idle_workers << worker
  unless frames == [::Protobuf::Rpc::Zmq::WORKER_READY_MESSAGE]
    write_to_frontend(frames)
  end
end