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.

Reply via email to