Package org.apache.storm.testing

Interface TestJob

public interface TestJob
This is the core interface for the storm java testing, usually we put our java unit testing logic in the run method. A sample code will be:

```java Testing.withSimulatedTimeLocalCluster(new TestJob() { public void run(Cluster cluster) { // your testing logic here. } }); ```

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    run(ILocalCluster cluster)
    run the testing logic with the cluster.

  • Method Details

    • run

      void run(ILocalCluster cluster) throws Exception
      run the testing logic with the cluster.
      Parameters:
      cluster - the cluster which created by Testing.withSimulatedTimeLocalCluster and Testing.withTrackedCluster.
      Throws:
      Exception