From 2c946a107444431e595fa855e4b2e646be83770b Mon Sep 17 00:00:00 2001 From: Mark Paluch Date: Tue, 19 Mar 2024 09:36:24 +0100 Subject: [PATCH] Use write locks for write guards instead of read locks. Closes #4665 --- .../core/messaging/DefaultMessageListenerContainer.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/spring-data-mongodb/src/main/java/org/springframework/data/mongodb/core/messaging/DefaultMessageListenerContainer.java b/spring-data-mongodb/src/main/java/org/springframework/data/mongodb/core/messaging/DefaultMessageListenerContainer.java index bde0154b8..10fbc7a6b 100644 --- a/spring-data-mongodb/src/main/java/org/springframework/data/mongodb/core/messaging/DefaultMessageListenerContainer.java +++ b/spring-data-mongodb/src/main/java/org/springframework/data/mongodb/core/messaging/DefaultMessageListenerContainer.java @@ -55,11 +55,11 @@ public class DefaultMessageListenerContainer implements MessageListenerContainer private final ReadWriteLock lifecycleMonitor = new ReentrantReadWriteLock(); private final Lock lifecycleRead = Lock.of(lifecycleMonitor.readLock()); - private final Lock lifecycleWrite = Lock.of(lifecycleMonitor.readLock()); + private final Lock lifecycleWrite = Lock.of(lifecycleMonitor.writeLock()); private final ReadWriteLock subscriptionMonitor = new ReentrantReadWriteLock(); private final Lock subscriptionRead = Lock.of(subscriptionMonitor.readLock()); - private final Lock subscriptionWrite = Lock.of(subscriptionMonitor.readLock()); + private final Lock subscriptionWrite = Lock.of(subscriptionMonitor.writeLock()); private boolean running = false;