QuanticPony opened a new pull request, #958: URL: https://github.com/apache/plc4x/pull/958
This PR adds a listener record processor (subscription operation) to the NiFi integration The implementation follows the mail discussion: https://lists.apache.org/thread/jt99jqwrlq9m5or72xc1lnf6hdrpmkct ## Additions * Add Plc4xListenerRecordProcessor: launches a dispatcher and reads from a queue stored messages * Add Plc4xListenerDispatcher: thread runner that connects to the PLC and stores messages into the queue * Changes needed to use the schema cache in the listener ## Other changes * Update README * Moved the timeout property to the BasePlc4xProcessor as all processors need it * Make sure all processors use the timeout on requests: Plc4xSinkProcessor and Plc4xSourceProcessor did not use it -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: dev-unsubscr...@plc4x.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
