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.