We seem to be getting loads of these errors in our topology.
1. Should I be getting these errors?
2. Is there anything I can do to mitigate this?
All seems to be working fine. That is the odd thing...
Thanks for any input!
mark
2016-06-22 15:57:01 STDIO [ERROR] Jun 22, 2016 3:57:01 PM com.lambdaworks.redis.protocol.ConnectionWatchdog reconnect
INFO: Reconnecting, last destination was blah.blah.blah.com
2016-06-22 15:57:01 STDIO [ERROR] Jun 22, 2016 3:57:01 PM com.lambdaworks.redis.protocol.ConnectionWatchdog reconnect
INFO: Reconnected to blah.blah.blah.com:6380
2016-06-22 15:57:01 STDIO [ERROR] Jun 22, 2016 3:57:01 PM com.lambdaworks.redis.protocol.ConnectionWatchdog reconnect
INFO: Reconnecting, last destination was blah.blah.blah.com:6380
2016-06-22 15:57:01 STDIO [ERROR] Jun 22, 2016 3:57:01 PM com.lambdaworks.redis.protocol.ConnectionWatchdog reconnect
INFO: Reconnected to blah.blah.blah.com:6380
2016-06-22 15:57:05 STDIO [ERROR] Jun 22, 2016 3:57:05 PM com.lambdaworks.redis.protocol.ConnectionWatchdog reconnect
INFO: Reconnecting, last destination was blah.blah.blah.com:6380
2016-06-22 15:57:05 STDIO [ERROR] Jun 22, 2016 3:57:05 PM com.lambdaworks.redis.protocol.ConnectionWatchdog reconnect
INFO: Reconnected to blah.blah.blah.com:6380
2016-06-22 15:57:10 STDIO [ERROR] Jun 22, 2016 3:57:10 PM com.lambdaworks.redis.protocol.ConnectionWatchdog reconnect
INFO: Reconnecting, last destination was blah.blah.blah.com:6380
2016-06-22 15:57:10 STDIO [ERROR] Jun 22, 2016 3:57:10 PM com.lambdaworks.redis.protocol.ConnectionWatchdog reconnect
INFO: Reconnected to blah.blah.blah.com:6380
I am connecting like this:
public static RedisConnection<String, String> getRegistrationRedisDataSource() {
String url = PropertiesButler.getProperty("redis.registration.url", true);
String password = PropertiesButler.getProperty("redis.registration.key", true);
int port = Integer.parseInt(PropertiesButler.getProperty("redis.registration.port", true));
int timeout = Integer.parseInt(PropertiesButler.getProperty("redis.registration.timeout", true));
RedisURI uri = new RedisURI();
uri.setSsl(true);
uri.setHost(url);
uri.setPort(port);
uri.setPassword(password);
uri.setTimeout(timeout);
uri.setUnit(TimeUnit.SECONDS);
RedisClient redisClient = RedisClient.create(uri);
RedisConnection<String, String> redisConnection = null;
try {
redisConnection = redisClient.connect();
}
catch (Exception e) {
log.error("Redis connection could not be made! Port is probably closed (is this dev?).", e);
if (!TmaticProperties.environment.in(Environment.dev)) {
throw e;
}
}
return redisConnection;
}