Skip to content

Commit 136e22e

Browse files
committed
Use write locks for write guards instead of read locks.
Closes #4665
1 parent af6da0f commit 136e22e

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

Diff for: spring-data-mongodb/src/main/java/org/springframework/data/mongodb/core/messaging/DefaultMessageListenerContainer.java

+2-2
Original file line numberDiff line numberDiff line change
@@ -55,11 +55,11 @@ public class DefaultMessageListenerContainer implements MessageListenerContainer
5555

5656
private final ReadWriteLock lifecycleMonitor = new ReentrantReadWriteLock();
5757
private final Lock lifecycleRead = Lock.of(lifecycleMonitor.readLock());
58-
private final Lock lifecycleWrite = Lock.of(lifecycleMonitor.readLock());
58+
private final Lock lifecycleWrite = Lock.of(lifecycleMonitor.writeLock());
5959

6060
private final ReadWriteLock subscriptionMonitor = new ReentrantReadWriteLock();
6161
private final Lock subscriptionRead = Lock.of(subscriptionMonitor.readLock());
62-
private final Lock subscriptionWrite = Lock.of(subscriptionMonitor.readLock());
62+
private final Lock subscriptionWrite = Lock.of(subscriptionMonitor.writeLock());
6363

6464
private boolean running = false;
6565

0 commit comments

Comments
 (0)