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;