Hi Grant, FlowFiles in NiFI are accessed transactionally. This transactionality is provided by the ProcessSession. So the transfer() method cannot put the FlowFIles on the next queue, as the session may be rolled back afterwards. You’ll want to see the StandardProcessSessin’s commit() method.
Thanks -Mark > On Mar 9, 2022, at 1:36 AM, Grant Guo <garfieldtige...@gmail.com> wrote: > > Hi, > > I am new to Nifi. I am investigating the source code by running the simple > Syslog example( > https://cwiki.apache.org/confluence/download/attachments/57904847/SyslogExample.xml?version=1&modificationDate=1446737325000&api=v2 > ) > > In "ListenSyslog" processor, I saw this line: "session.transfer(flowFile, > REL_SUCCESS)", but looks like transfer(..) function doesn't push the > FlowFile to Connection. So I am wondering how the FlowFiles are enqueued to > StandardConnection. I know there is "enqueue(...)" function in class > StandardConnection , but I can't find where it gets called. > > Please advise. > > Thanks > -- > > Sincerely > > Grant
