0006043: ConcurrentConnectionManager expects nodeId-channel in the white

list, but only the nodeId is put in the white list
JumpMind · Oct 23, 2023 · 1bcef33 · 1bcef33
1 parent 7c8a5ec
commit 1bcef33
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
@@ -126,7 +126,7 @@ synchronized public boolean reserveConnection(String nodeId, String channelId, S
         long timeout = parameterService.getLong(ParameterConstants.CONCURRENT_RESERVATION_TIMEOUT);
         removeTimedOutReservations(reservations);
         if (reservations.size() < maxPoolSize || reservations.containsKey(reservationId)
-                || whiteList.contains(reservationId)) {
+                || whiteList.contains(nodeId)) {
             Reservation existingReservation = reservations.get(reservationId);
             if (existingReservation == null
                     || existingReservation.getType() == ReservationType.SOFT) {