Hello all,

I'm working to a processor and a service.

My work is based on source codes from 
https://github.com/pcgrenier/nifi-examples/tree/sample-processor


My problem is this code


        runner = TestRunners.newTestRunner(new StartProcessor());

        :

        .


        runner.enqueue("THIS IS A CONTENT".getBytes());
        runner.run(1);

which stops with :

IllegalStateException: FlowFile[1,71039521870109.mockFlowFile,0B] has already 
been transferred

runner.run(1)  ---> looks like is missing the contente I put into the queue.

What is the correct way to add a fake flowfile into the queue?
What's wrong with the above code ?

Thanks in advance.
AP

Reply via email to