Hi Unai! Would this be a single thread, just listening? Is this pure exception based processing ( where you only listen for things ) or is it possible to have to simulate this by polling some of the endpoints?
On May 17, 2023 at 10:28:24 AM, Unai Leria ([email protected]) wrote: Hi NiFi community! br/> < 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 br/>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 ] br/> < 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. br/>That disppatcher puts events into a queue from which the processor reads and creates FlowFiles. br/> < 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. br/> < Any thoughts would be greatly appreciated! br/> < Thank you for your time, br/> < Unai Lería br/> <
