rpcServer.register(peerID, this);
   protected void doJoin() throws DistributedException   {      DistributedPipeOutput output = new DistributedPipeOutput(pipeID, queue);      if (!rpcServer.registerUnique(pipeID, output))      {         throw new IllegalStateException("More than one server subordinates tried " +                                         "to registers using id=" + pipeID);      }      rpcServer.register(queue.getName(), this);   }