code: public void launchWorker(Map conf, IContext sharedContext, String topologyId,
                               String supervisorId, Integer port, String workerId,
                               ConcurrentHashMap<String, String> workerThreadPidsAtom) throws Exception {
          String pid = UUID.randomUUID().toString();
          WorkerShutdown worker = Worker.mk_worker(conf, sharedContext, topologyId, supervisorId, port, workerId, null);
          ProcessSimulator.registerProcess(pid, worker);
          workerThreadPidsAtom.put(workerId, pid);
      }
docs: launch a worker in local mode