tenthe opened a new pull request, #2340: URL: https://github.com/apache/plc4x/pull/2340
Hi all, in Apache StreamPipes we encountered an issue where, if a connection drops during a lease and reconnection subsequently fails, the container leaves behind a “zombie” `leasedConnection` as well as a non-empty queue containing futures that have already completed. To address this, we added a `queue.clear()` call in the `ConnectionContainer`. For StreamPipes we had temporarily copied the corresponding PLC4X classes [1] to apply this fix on our side. If this change is acceptable from your perspective, we can remove the duplicated PLC4X classes from the StreamPipes codebase. I hope this update makes sense. If there’s anything else I should adjust, please let me know. [1] https://github.com/apache/streampipes/tree/dev/streampipes-extensions/streampipes-connectors-plc/src/main/java/org/apache/streampipes/extensions/connectors/plc/cache -- 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: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
