diff --git a/src/main/java/org/springframework/data/redis/core/RedisConnectionUtils.java b/src/main/java/org/springframework/data/redis/core/RedisConnectionUtils.java index 02feabe07..3f65b35c2 100644 --- a/src/main/java/org/springframework/data/redis/core/RedisConnectionUtils.java +++ b/src/main/java/org/springframework/data/redis/core/RedisConnectionUtils.java @@ -81,14 +81,8 @@ public abstract class RedisConnectionUtils { RedisConnection conn = factory.getConnection(); - boolean synchronizationActive = TransactionSynchronizationManager.isSynchronizationActive(); - - if (bind || synchronizationActive) { + if (bind) { connHolder = new RedisConnectionHolder(conn); - if (synchronizationActive) { - TransactionSynchronizationManager.registerSynchronization(new RedisConnectionSynchronization( - connHolder, factory, true)); - } TransactionSynchronizationManager.bindResource(factory, connHolder); return connHolder.getConnection(); }