Package net.rubyeye.xmemcached

Examples of net.rubyeye.xmemcached.MemcachedClient.shutdown()

197
198
199
200
201
202
203
204
205
206
207
    // confirm
    Assert.assertNull(newClient.get("queue1/close"));
    // null
    Assert.assertNull(newClient.get("queue1"));

    newClient.shutdown();
  }

  public void testPerformance() throws Exception {
    long start = System.currentTimeMillis();
    for (int i = 0; i < 10000; i++) {
View Full Code Here
88
89
90
91
92
93
94
95
96
97
98
      Thread.sleep(5000);
      assertEquals("response from server1", client.get("a"));
    } finally {
      memServer1.stop();
      memServer2.stop();
      client.shutdown();
    }

  }

  @Test
View Full Code Here
134
135
136
137
138
139
140
141
142
143
144
      assertEquals("response from server1", client.get("b"));
    } finally {
      if (memServer1 != null)
        memServer1.stop();
      memServer2.stop();
      client.shutdown();
    }

  }

  @Test
View Full Code Here
194
195
196
197
198
199
200
201
202
203
204
      assertEquals("response from server1", client.get("a"));

    } finally {
      memServer1.stop();
      memServer2.stop();
      client.shutdown();
    }

  }

  @Test
View Full Code Here
229
230
231
232
233
234
235
236
237
238
239
            .getMessage());
        assertTrue(true);
      }
    } finally {
      memServer1.stop();
      client.shutdown();
    }

  }

  @Test
View Full Code Here
268
269
270
271
272
273
274
275
276
277
278
        assertTrue(true);
      }
    } finally {
      memServer1.stop();
      memServer2.stop();
      client.shutdown();
    }

  }

  @Test
View Full Code Here
301
302
303
304
305
306
307
308
309
310
311
            e.getMessage());
        assertTrue(true);
      }
    } finally {
      memServer1.stop();
      client.shutdown();
    }

  }

  @Test
View Full Code Here
334
335
336
337
338
339
340
341
342
343
344
      Thread.sleep(1000);
      assertEquals("response from server1", client.get("a"));
    } finally {
      memServer1.stop();
      memServer2.stop();
      client.shutdown();
    }

  }

}
View Full Code Here
66
67
68
69
70
71
72
73
74
75
76
  }

  public void testCreateClientWithEmptyServers() throws Exception {
    MemcachedClient client = new XMemcachedClient();
    assertFalse(client.isShutdown());
    client.shutdown();
    assertTrue(client.isShutdown());

    MemcachedClientBuilder builder = new XMemcachedClientBuilder();
    client = builder.build();
    assertFalse(client.isShutdown());
View Full Code Here
72
73
74
75
76
77
78
79
80
81
82
    assertTrue(client.isShutdown());

    MemcachedClientBuilder builder = new XMemcachedClientBuilder();
    client = builder.build();
    assertFalse(client.isShutdown());
    client.shutdown();
    assertTrue(client.isShutdown());
  }

  protected void createClients() throws IOException, Exception,
      TimeoutException, InterruptedException, MemcachedException {
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.