JedisPool/Jedis Resource Handling Example

LambdaJedis.java

private interface RedisCallback<T> {
  T apply(Jedis jedis) throws IOException;
}

private <T> T withRedis(RedisCallback<T> callback) throws IOException {
  Objects.requireNonNull(redisConnectionPool, "redis connection pool must be initialized");
  Objects.requireNonNull(callback, "callback needs to be provided");
  try(Jedis jedis = redisConnectionPool.getResource()) {
   T result = callback.apply(jedis);
   redisConnectionPool.returnResource(jedis); 
   return result;
  } catch(IOException ioe) {
    redisConnectionPool.returnBrokenResource(jedis);
    throw ioe;
  } catch(Exception e) {
    redisConnectionPool.returnBrokenResource(jedis);
    throw new RuntimeException("Error working with Redis", e);
  }
}