diff --git a/spring-data-mongodb/src/main/java/org/springframework/data/mongodb/ReactiveMongoDatabaseUtils.java b/spring-data-mongodb/src/main/java/org/springframework/data/mongodb/ReactiveMongoDatabaseUtils.java
index e55b741cd..9067b74ec 100644
--- a/spring-data-mongodb/src/main/java/org/springframework/data/mongodb/ReactiveMongoDatabaseUtils.java
+++ b/spring-data-mongodb/src/main/java/org/springframework/data/mongodb/ReactiveMongoDatabaseUtils.java
@@ -62,7 +62,7 @@ public class ReactiveMongoDatabaseUtils {
 			return Mono.just(true);
 		}
 
-		return TransactionSynchronizationManager.currentTransaction() //
+		return TransactionSynchronizationManager.forCurrentTransaction() //
 				.map(it -> {
 
 					ReactiveMongoResourceHolder holder = (ReactiveMongoResourceHolder) it.getResource(databaseFactory);
@@ -137,7 +137,7 @@ public class ReactiveMongoDatabaseUtils {
 
 		Assert.notNull(factory, "DatabaseFactory must not be null!");
 
-		return TransactionSynchronizationManager.currentTransaction()
+		return TransactionSynchronizationManager.forCurrentTransaction()
 				.filter(TransactionSynchronizationManager::isSynchronizationActive) //
 				.flatMap(synchronizationManager -> {
 
@@ -210,7 +210,7 @@ public class ReactiveMongoDatabaseUtils {
 			this.resourceHolder = resourceHolder;
 		}
 
-		/* 
+		/*
 		 * (non-Javadoc)
 		 * @see org.springframework.transaction.reactive.ReactiveResourceSynchronization#shouldReleaseBeforeCompletion()
 		 */
@@ -219,7 +219,7 @@ public class ReactiveMongoDatabaseUtils {
 			return false;
 		}
 
-		/* 
+		/*
 		 * (non-Javadoc)
 		 * @see org.springframework.transaction.reactive.ReactiveResourceSynchronization#processResourceAfterCommit(java.lang.Object)
 		 */
@@ -233,7 +233,7 @@ public class ReactiveMongoDatabaseUtils {
 			return Mono.empty();
 		}
 
-		/* 
+		/*
 		 * (non-Javadoc)
 		 * @see org.springframework.transaction.reactive.ReactiveResourceSynchronization#afterCompletion(int)
 		 */
@@ -252,7 +252,7 @@ public class ReactiveMongoDatabaseUtils {
 			});
 		}
 
-		/* 
+		/*
 		 * (non-Javadoc)
 		 * @see org.springframework.transaction.reactive.ReactiveResourceSynchronization#releaseResource(java.lang.Object, java.lang.Object)
 		 */
diff --git a/spring-data-mongodb/src/test/java/org/springframework/data/mongodb/ReactiveMongoDatabaseUtilsUnitTests.java b/spring-data-mongodb/src/test/java/org/springframework/data/mongodb/ReactiveMongoDatabaseUtilsUnitTests.java
index ec840a4c0..d50cdd914 100644
--- a/spring-data-mongodb/src/test/java/org/springframework/data/mongodb/ReactiveMongoDatabaseUtilsUnitTests.java
+++ b/spring-data-mongodb/src/test/java/org/springframework/data/mongodb/ReactiveMongoDatabaseUtilsUnitTests.java
@@ -116,7 +116,7 @@ public class ReactiveMongoDatabaseUtilsUnitTests {
 
 		operator.execute(tx -> {
 
-			return TransactionSynchronizationManager.currentTransaction().doOnNext(synchronizationManager -> {
+			return TransactionSynchronizationManager.forCurrentTransaction().doOnNext(synchronizationManager -> {
 
 				assertThat(synchronizationManager.isSynchronizationActive()).isTrue();
 				assertThat(tx.isNewTransaction()).isTrue();