(plc4x) branch develop updated: Fix empty queue with broken connections (#2340)

[sruehl]

This is an automated email from the ASF dual-hosted git repository.

sruehl pushed a commit to branch develop
in repository https://gitbox.apache.org/repos/asf/plc4x.git


The following commit(s) were added to refs/heads/develop by this push:
     new b430d0f951 Fix empty queue with broken connections (#2340)
b430d0f951 is described below

commit b430d0f951d94722663acf9c9b9f22a921aa7e04
Author: Philipp Zehnder <ten...@users.noreply.github.com>
AuthorDate: Tue Nov 11 16:36:40 2025 +0100

    Fix empty queue with broken connections (#2340)
    
    * fix: clear queue on connection failure
    
    * fix: remove unnecessary whitespace in ConnectionContainer
---
 .../main/java/org/apache/plc4x/java/utils/cache/ConnectionContainer.java | 1 +
 1 file changed, 1 insertion(+)

diff --git 
a/plc4j/tools/connection-cache/src/main/java/org/apache/plc4x/java/utils/cache/ConnectionContainer.java
 
b/plc4j/tools/connection-cache/src/main/java/org/apache/plc4x/java/utils/cache/ConnectionContainer.java
index a40e722699..b6abef30e0 100644
--- 
a/plc4j/tools/connection-cache/src/main/java/org/apache/plc4x/java/utils/cache/ConnectionContainer.java
+++ 
b/plc4j/tools/connection-cache/src/main/java/org/apache/plc4x/java/utils/cache/ConnectionContainer.java
@@ -152,6 +152,7 @@ class ConnectionContainer {
                 // If something goes wrong, close all waiting futures 
exceptionally.
                 LOGGER.warn("Can't get connection for {} complete queue items 
exceptionally", connectionUrl, e);
                 queue.forEach(future -> future.completeExceptionally(e));
+                queue.clear();
                 connection = null;
             }
         }