Package net.rubyeye.xmemcached

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


  }

  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


    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

    assertEquals(1, client.getAvaliableServers().size());
    assertEquals(5, client.getConnectionSizeBySocketAddress(serverAddress));
    assertEquals(5, server.sessionCounter.get());

    server.stop();
    client.shutdown();

  }
 
  public void testDisableHealSession() throws Exception {
    MockServer server = new MockServer();
View Full Code Here

    //Still empty.
    assertEquals(0, client.getAvaliableServers().size());
    assertEquals(0, client.getConnectionSizeBySocketAddress(serverAddress));

    server.stop();
    client.shutdown();

  }

  @Override
  public MemcachedClientBuilder createWeightedBuilder() throws Exception {
View Full Code Here

  }

  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

    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

    assertEquals(1, client.getAvaliableServers().size());
    assertEquals(5, client.getConnectionSizeBySocketAddress(serverAddress));
    assertEquals(5, server.sessionCounter.get());

    server.stop();
    client.shutdown();

  }

  @Override
  public MemcachedClientBuilder createWeightedBuilder() throws Exception {
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.