Package org.apache.storm

Class ProcessSimulator

java.lang.Object

org.apache.storm.ProcessSimulator

public class ProcessSimulator
extends Object

In local mode, ProcessSimulator keeps 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

Modifier and Type	Method	Description
static Collection<Shutdownable>	getAllProcessHandles()	Get all process handles.
static void	killAllProcesses()	Kill all processes.
static void	killProcess(String pid)	Kill a process.
static void	registerProcess(String pid, Shutdownable shutdownable)	Register a process' handle.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

processMap

protected static ConcurrentHashMap<String,Shutdownable> processMap

Constructor Details

ProcessSimulator

public ProcessSimulator()

Method Details

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.