This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
import java.util.Arrays; | |
import java.util.Collection; | |
import java.util.Date; | |
import redis.clients.jedis.JedisShardInfo; | |
import redis.clients.jedis.ShardedJedis; | |
import redis.clients.util.JedisDynamicShardsProvider; | |
public class Main { | |
public static void main(final String[] argv) { |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
@Singleton | |
public class JedisManager implements Runnable { | |
public static final String POLLING_INTERVAL = "jedismanager.configuration.polling.intervall.in.millis"; | |
public static final String FAILURE_THRESHOLD = "jedismanager.configuration.failure.threshold"; | |
public static final String START_ON_INSTANCIATION = "jedismanager.configuration.start.on.instanciation"; | |
private static final String VALID_PONG_RESPONSE = "PONG"; | |
private final JedisProvider jedisProvider; // Simple interface for DI | |
private final RedisConfigurationDAO dao; // | |
private final JedisDynamicShardsProvider shardsProvider; |