Enqueue FlowFiles
Before triggering a Processor to run, it is usually necessary to enqueue FlowFiles for
the Processor to process. This can be achieved by using the enqueue
methods of the TestRunner
class. The enqueue
method
has several different overrides, and allows data to be added in the form of a
byte[]
, InputStream
, or Path
.
Each of these methods also supports a variation that allows a Map<String,
String>
to be added to support FlowFile attributes.
Additionally, there is an enqueue
method that takes a var-args of
FlowFile objects. This can be useful, for example, to obtain the output of a Processor and
then feed this to the input of the Processor.