|
|
@ -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; |
|
|
|
|
|
|
|