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
