org.apache.storm

Class Testing.CapturedTopology<T>

java.lang.Object

org.apache.storm.Testing.CapturedTopology<T>

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 Summary

Fields

Modifier and Type	Field and Description
TupleCaptureBolt	capturer a Bolt that will hold all of the captured data.
T	topology

Constructor Summary

Constructors

Constructor and Description
CapturedTopology(T topology, TupleCaptureBolt capturer)

Method Summary

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

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)