diff --git a/redis/modules/src/main/java/org/atmosphere/plugin/redis/RedisUtil.java b/redis/modules/src/main/java/org/atmosphere/plugin/redis/RedisUtil.java
index 32c99bf69..a0591b0e3 100644
--- a/redis/modules/src/main/java/org/atmosphere/plugin/redis/RedisUtil.java
+++ b/redis/modules/src/main/java/org/atmosphere/plugin/redis/RedisUtil.java
@@ -259,7 +259,7 @@ private void disconnectPublisher() {
     }
 
     private Object getLockingObject() {
-        return sharedPool ? jedisPool : jedisPublisher;
+        return sharedPool ? new Object() : jedisPublisher;
     }
 
     public static interface Callback {