code: func (w *Worker) RegisterRPCJob(rpcJob RPCJob) error {
  	if w.registered {
  		return constants.ErrRPCJobAlreadyRegistered
  	}
  
  	job := w.parsedRPCJob(rpcJob)
  	workers.Process(rpcQueue, job, w.concurrency)
  	w.registered = true
  	return nil
  }
docs: // RegisterRPCJob registers a RPC job