Package org.apache.storm

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 Summary

Fields

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

Constructor Summary

Constructors

Constructor	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 Details

topology

public final T topology

capturer

public final TupleCaptureBolt capturer

a Bolt that will hold all of the captured data.

Constructor Details

CapturedTopology

public CapturedTopology(T topology,
 TupleCaptureBolt capturer)