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 ) ; }
launch a worker in local mode