Hi NiFi community! 

I'm working on a PLC subscriber/listener processor to improve the 
Apache/PLC4X's NiFi integration and a questions about the possible 
implementation have raised on the PLC4x community 
The processor can be found here: [ 
https://github.com/zylklab/plc4x/blob/feature/nifi-integration-record-listener/plc4j/integrations/apache-nifi/nifi-plc4x-processors/src/main/java/org/apache/plc4x/nifi/Plc4xListenRecordProcessor.java
 | 
https://github.com/zylklab/plc4x/blob/feature/nifi-integration-record-listener/plc4j/integrations/apache-nifi/nifi-plc4x-processors/src/main/java/org/apache/plc4x/nifi/Plc4xListenRecordProcessor.java
 ] 

At the moment I have made the processor trying to follow the already 
implemented listeners in NiFi: starting a daemon thread with a dispatcher that 
connects to the PCL and waits for messages. 
That dispatcher puts events into a queue from which the processor reads and 
creates FlowFiles. 

The main question is if creating a thread for every processor that are not in 
the thread pools and governed by the Nifi scheduler is a bad idea. And what 
could be the effects be on a NiFi instance of multiple of this processors. 


Any thoughts would be greatly appreciated! 

Thank you for your time, 

Unai LerĂ­a 



Reply via email to