Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- package com.exacttarget.bloomin.jedis;
- import com.google.common.base.Preconditions;
- import com.twitter.common.net.pool.Connection;
- import redis.clients.jedis.Jedis;
- public class JedisConnection implements Connection<Jedis, Jedis> {
- private final Jedis jedis;
- public JedisConnection(Jedis jedis) {
- this.jedis = Preconditions.checkNotNull(jedis);
- }
- @Override
- public Jedis get() {
- return jedis;
- }
- @Override
- public boolean isValid() {
- return true;
- }
- @Override
- public void close() {
- try {
- try {
- jedis.quit();
- } catch (Exception ignored) {
- //ignored
- }
- jedis.disconnect();
- } catch (Exception ignored) {
- //ignored
- }
- }
- @Override
- public Jedis getEndpoint() {
- return jedis;
- }
- }
Add Comment
Please, Sign In to add comment