improve removeSection method to remove sections with the same propert…

…y key and value
quickfix-j · Feb 16, 2024 · 7d16ec4 · 7d16ec4
1 parent 24d836b
commit 7d16ec4
Showing 1 changed file with 5 additions and 4 deletions.
diff --git a/quickfixj-core/src/main/java/quickfix/SessionSettings.java b/quickfixj-core/src/main/java/quickfix/SessionSettings.java
@@ -887,12 +887,13 @@ public void removeSection(final SessionID sessionID) throws ConfigError {
     }
 
     public void removeSection(final String propertyKey, final String propertyValue) throws ConfigError {
-        SessionID sessionIdToRemove = sections.entrySet().stream()
+        List<SessionID> sessionIDs = sections.entrySet().stream()
                 .filter(entry -> propertyValue.equals(entry.getValue().get(propertyKey)))
                 .map(Map.Entry::getKey)
-                .findFirst()
-                .orElseThrow(() -> new ConfigError("Session not found"));
+                .collect(Collectors.toList());
 
-        sections.remove(sessionIdToRemove);
+        for (SessionID sessionID : sessionIDs) {
+            this.removeSection(sessionID);
+        }
     }
 }