I think you could call any of the enqueue methods multiple times to queue multiple flow files.
If you really want to use the one that takes var args of FlowFile, then you would need to create the MockFlowFiles yourself doing something like this... https://github.com/apache/nifi/blob/main/nifi-mock/src/main/java/org/apache/nifi/util/StandardProcessorTestRunner.java#L443-L448 Instead of creating a new MockProcessSession, you would get the ProcessSessionFactory from the TestRunner and then call createProcessSession(). On Mon, Aug 31, 2020 at 9:01 AM Russell Bateman <[email protected]> wrote: > In my JUnit testing of a custom processor, I need to queue up at least > two flowfiles. I see that there is an implementation of > TestRunner.enqueue()that takes*a list of flowfiles*, but I'm used to > using the implementation of this method that creates me a flowfile from > bytes or a stream. I do not know how to create a flowfile from scratch > inside test code. MockFlowFile's two constructors are no help. Getting > there via interface ProcessorSessionseems a long road to travel just for > this. > > Examples using TestRunner.enqueue( FlowFile ... flowfiles ) do not > abound out there in Googleland. Has someone else done this? > > Thanks. >
