BlockTester |
FlowTester.createBlockTesterFor(String blockID) |
Create a block tester for the specified block ID.
|
List<Tuple> |
FlowTester.TupleDequeueHandle.dequeue(int minTuples) |
Poll the handle, returning any tuples found.
|
void |
FlowTester.enqueueTuple(String blockInstanceID,
FlowTester.ITupleInitializer initializer) |
Enqueue a tuple on the specified flow block instance.
|
NodeList |
BlockTester.getExternalAdapterXMLConfigForType(String adapterType) |
Return the current external XML adapter configuration for the specified adapter type.
|
Map<String,String> |
BlockTester.getModuleParametersForModuleBlock(String[] inputPortNames,
String[] outputPortNames,
com.typesafe.config.Config blockInstanceConfig) |
Deprecated.
|
Map<String,String> |
BlockTester.getModuleParametersForModuleBlock(Set<String> inputPortNames,
Set<String> outputPortNames,
com.typesafe.config.Config blockInstanceConfig) |
For a block of type MODULE , given a block instance configuration for this block, return the block
instance's module parameters.
|
com.typesafe.config.Config |
BlockTester.getTransformedConfigForParentBlock(String[] inputPortNames,
String[] outputPortNames,
com.typesafe.config.Config blockInstanceConfig) |
Deprecated.
|
com.typesafe.config.Config |
BlockTester.getTransformedConfigForParentBlock(Set<String> inputPortNames,
Set<String> outputPortNames,
com.typesafe.config.Config blockInstanceConfig) |
For a block of type DEPENDENT , given a block instance configuration for this block, return the block
instance's transformed parent configuration.
|
Collection<FlowEngine.TupleLoggingInfo> |
FlowTester.getTupleLogging(Optional<String> portPathRegexp) |
Display tuple logging info as a map of logging status (enabled or disabled), indexed by port path
|
void |
FlowTester.init() |
Initialize a flow tester.
|
FlowTester.TupleDequeueHandle |
FlowTester.initTupleDequeue(String blockInstanceID,
long pollMS) |
Initialize tuple dequeueing from the specified block instance ID.
|
void |
FlowTester.runFlow(FlowConfig flowConfig) |
Start this tester's flow.
|
Collection<FlowEngine.TupleLoggingInfo> |
FlowTester.setTupleLogging(Optional<String> portPathRegexp,
boolean enabled) |
Set tuple logging.
|