Package redis.clients.jedis

Examples of redis.clients.jedis.Jedis.disconnect()

43
44
45
46
47
48
49
50
51
52
53
    }
   
    @Test
    public void testTestJedisConnection_Fail() {
        final Jedis jedis = createJedis(CONFIG);
        jedis.disconnect();
        Assert.assertFalse(JedisUtils.testJedisConnection(jedis));
    }
   
    @Test
    public void testReconnect_Success() {
View Full Code Here
126
127
128
129
130
131
132
133
134
135
136
      return false;
    }
    finally {
      if (jedis != null) {
        try {
          jedis.disconnect();
          jedis.close();
        }
        catch (Exception ex) {
          // Continue
        }
View Full Code Here
40
41
42
43
44
45
46
47
48
49
50
        if (password != null)
        {
            jedis.auth(password);
        }
        jedis.flushDB();
        jedis.disconnect();
    }

    /**
     * Start Redis server.
     *
 
View Full Code Here
167
168
169
170
171
172
173
174
175
176
177
    } finally {

      if (jedis != null) {
        try {

          jedis.disconnect();
          jedis.close();
        } catch (Exception e) {

          e.printStackTrace();
        }
View Full Code Here
3147
3148
3149
3150
3151
3152
3153
3154
3155
3156
3157
      return temp.ping().equalsIgnoreCase("pong");
    } catch (Exception e) {
      return false;
    } finally {
      if (temp != null) {
        temp.disconnect();
        temp.close();
      }
    }
  }
View Full Code Here
16
17
18
19
20
21
22
23
24
25
26
    public static void main(String[] args) throws IOException {
        Jedis jedis = new Jedis("localhost");
        jedis.flushAll();
        jedis.quit();
        jedis.disconnect();

        List<JedisShardInfo> shards = new ArrayList<JedisShardInfo>();
        shards.add(new JedisShardInfo("localhost"));
        Config config = new Config();
        Seek.configure(config, shards);
View Full Code Here
43
44
45
46
47
48
49
50
51
52
53
            seek.remove(String.valueOf(n), "84689862");
        }
        long elapsed = System.nanoTime() - start;

        jedis.quit();
        jedis.disconnect();

        System.out.println(((1000 * SEARCHES) / (elapsed / 1000000))
                + " indexaciones por segundo");
    }

View Full Code Here
16
17
18
19
20
21
22
23
24
25
26
    public static void main(String[] args) throws IOException {
        Jedis jedis = new Jedis("localhost");
        jedis.flushAll();
        jedis.quit();
        jedis.disconnect();

        List<JedisShardInfo> shards = new ArrayList<JedisShardInfo>();
        shards.add(new JedisShardInfo("localhost"));
        Config config = new Config();
        Seek.configure(config, shards);
View Full Code Here
41
42
43
44
45
46
47
48
49
50
51
            entry.save();
        }
        long elapsed = System.nanoTime() - start;

        jedis.quit();
        jedis.disconnect();

        System.out.println(((1000 * SEARCHES) / (elapsed / 1000000))
                + " indexaciones por segundo");
    }

View Full Code Here
64
65
66
67
68
69
70
71
72
73
74
          jedis.get(key);
        }
       
        completionCounter.countDown();
       
        jedis.disconnect();
      }
    }, "CacheClient-"+clientCounter.incrementAndGet()).start();
  }
 
  private String generateCacheKey() {
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.