0006044: ConcurrentConnectionManager expects nodeId-channel in the white

list, but only the nodeId is put in the white list
JumpMind · Oct 23, 2023 · fa12c5a · fa12c5a
1 parent 1075d94
commit fa12c5a
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...tric-core/src/main/java/org/jumpmind/symmetric/transport/ConcurrentConnectionManager.java b/...tric-core/src/main/java/org/jumpmind/symmetric/transport/ConcurrentConnectionManager.java
@@ -134,7 +134,7 @@ public synchronized ReservationStatus reserveConnection(String nodeId, String ch
                 log.info(message, nodeId, channelId, poolId);
             }
             return ReservationStatus.NOT_FOUND;
-        } else if (reservations.size() < maxPoolSize || existingReservation != null || whiteList.contains(reservationId)) {
+        } else if (reservations.size() < maxPoolSize || existingReservation != null || whiteList.contains(nodeId)) {
             if (existingReservation == null || existingReservation.getType() == ReservationType.SOFT) {
                 reservations.put(reservationId, new Reservation(reservationId,
                         reservationRequest == ReservationType.SOFT ? System.currentTimeMillis()