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 Details

  • 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.