Package org.apache.storm
Class ProcessSimulator
- java.lang.Object
-
- org.apache.storm.ProcessSimulator
-
public class ProcessSimulator extends Object
In local mode,ProcessSimulatorkeeps track of Shutdownable objects in place of actual processes (in cluster mode).
-
-
Field Summary
Fields Modifier and Type Field Description protected static ConcurrentHashMap<String,Shutdownable>processMap
-
Constructor Summary
Constructors Constructor Description ProcessSimulator()
-
Method Summary
All Methods Static Methods Concrete Methods Modifier and Type Method Description static Collection<Shutdownable>getAllProcessHandles()Get all process handles.static voidkillAllProcesses()Kill all processes.static voidkillProcess(String pid)Kill a process.static voidregisterProcess(String pid, Shutdownable shutdownable)Register a process' handle.
-
-
-
Field Detail
-
processMap
protected static ConcurrentHashMap<String,Shutdownable> processMap
-
-
Method Detail
-
registerProcess
public static void registerProcess(String pid, Shutdownable shutdownable)
Register a process' handle.
-
getAllProcessHandles
public static Collection<Shutdownable> getAllProcessHandles()
Get all process handles.
-
killProcess
public static void killProcess(String pid)
Kill a process.
-
killAllProcesses
public static void killAllProcesses()
Kill all processes.
-
-