Class Testing.CapturedTopology<T>

java.lang.Object
org.apache.storm.Testing.CapturedTopology<T>
Type Parameters:
T - the topology (tracked or regular)
Enclosing class:
Testing

public static final class Testing.CapturedTopology<T> extends Object
A topology that has all messages captured and can be read later on. This is intended mostly for internal testing.
  • Field Details

    • topology

      public final T topology
    • capturer

      public final TupleCaptureBolt capturer
      a Bolt that will hold all of the captured data.
  • Constructor Details