Class LocalCluster

java.lang.Object
org.apache.storm.LocalCluster
All Implemented Interfaces:
AutoCloseable, Nimbus.Iface, ILocalCluster, ILocalClusterTrackedTopologyAware

public class LocalCluster extends Object implements ILocalClusterTrackedTopologyAware, Nimbus.Iface
A stand alone storm cluster that runs inside a single process. It is intended to be used for testing. Both internal testing for Apache Storm itself and for people building storm topologies.

LocalCluster is an AutoCloseable so if you are using it in tests you can use a try block to be sure it is shut down.

try (LocalCluster cluster = new LocalCluster()) { // Do some tests } // The cluster has been shut down.