Class 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 Detail

      • topology

        public final T topology
      • capturer

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

      • CapturedTopology

        public CapturedTopology​(T topology,
                                TupleCaptureBolt capturer)