remove connection

NucleoTeam · Oct 26, 2023 · 6807023 · 6807023
1 parent f0663b7
commit 6807023
Show file tree

Hide file tree

Showing 3 changed files with 13 additions and 6 deletions.
diff --git a/buildSrc/src/main/groovy/nucleodb.app.gradle b/buildSrc/src/main/groovy/nucleodb.app.gradle
@@ -3,7 +3,7 @@ plugins {
 }
 
 group = 'com.nucleodb'
-version = '1.7.3'
+version = '1.7.4'
 
 repositories {
     mavenCentral()

diff --git a/buildSrc/src/main/groovy/nucleodb.library.gradle b/buildSrc/src/main/groovy/nucleodb.library.gradle
@@ -3,7 +3,7 @@ plugins {
 }
 
 group = 'com.nucleodb'
-version = '1.9.3'
+version = '1.9.4'
 
 repositories {
     mavenCentral()

diff --git a/library/src/main/java/com/nucleocore/library/database/tables/ConnectionHandler.java b/library/src/main/java/com/nucleocore/library/database/tables/ConnectionHandler.java
@@ -203,14 +203,21 @@ private void addConnection(Connection connection){
     this.putConnectionInKey(connection.getFromKey()+connection.getToKey()+connection.getLabel(), connection);
     allConnections.add(connection);
   }
-  private void removeConnection(Connection connection){
-    connectionByUUID.remove(connection.getUuid());
-    String key = connection.getFromKey();
+
+  private void removeByKey(String key, Connection connection){
     if(connections.containsKey(key)){
-      allConnections.remove(connection);
       connections.get(key).remove(connection);
     }
   }
+
+  private void removeConnection(Connection connection){
+    connectionByUUID.remove(connection.getUuid());
+    String connectionKey = connection.getFromKey();
+    this.removeByKey(connectionKey, connection);
+    this.removeByKey(connection.getFromKey()+connection.getLabel(), connection);
+    this.removeByKey(connection.getFromKey()+connection.getToKey()+connection.getLabel(), connection);
+    allConnections.remove(connection);
+  }
   public void consume() {
     if (this.config.getBootstrap() != null) {
       String consumer = UUID.randomUUID().toString();