code: protected void reconnect() {
  		disconnect().then(ok -> {
  			logger.info("Trying to reconnect...");
  			scheduler.schedule(this::connect, 5, TimeUnit.SECONDS);
  		}).catchError(cause -> {
  			logger.warn("Unable to disconnect from Redis server!", cause);
  			scheduler.schedule(this::connect, 5, TimeUnit.SECONDS);
  		});
  	}
docs: --- RECONNECT ---