diff --git a/src/main/java/com/corundumstudio/socketio/store/RedisStoreFactory.java b/src/main/java/com/corundumstudio/socketio/store/RedisStoreFactory.java
index 67966c6..baebd7e 100644
--- a/src/main/java/com/corundumstudio/socketio/store/RedisStoreFactory.java
+++ b/src/main/java/com/corundumstudio/socketio/store/RedisStoreFactory.java
@@ -30,8 +30,8 @@ public class RedisStoreFactory extends BaseStoreFactory {
     private final Long nodeId = (long) (Math.random() * 1000000);
 
     private Jedis redisClient = new Jedis("127.0.0.1", 6379);
-    private Jedis redisPub = new Jedis("127.0.0.1", 6379);
-    private Jedis redisSub = new Jedis("127.0.0.1", 6379);
+    private Jedis redisPub = redisClient;
+    private Jedis redisSub = redisClient;
 
     private PubSubRedisStore pubSubRedisStore;