net.spy.memcached.MemcachedClient.shutdown()方法的使用及代码示例

x33g5p2x  于2022-01-25 转载在 其他  
字(4.6k)|赞(0)|评价(0)|浏览(301)

本文整理了Java中net.spy.memcached.MemcachedClient.shutdown()方法的一些代码示例,展示了MemcachedClient.shutdown()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。MemcachedClient.shutdown()方法的具体详情如下:
包路径:net.spy.memcached.MemcachedClient
类名称:MemcachedClient
方法名:shutdown

MemcachedClient.shutdown介绍

[英]Shut down immediately.
[中]立即关闭。

代码示例

代码示例来源:origin: apache/hbase

  1. @Override
  2. public void shutdown() {
  3. client.shutdown();
  4. }

代码示例来源:origin: jooby-project/jooby

  1. public void destroy() {
  2. if (client != null) {
  3. client.shutdown(shutdownTimeout, TimeUnit.MILLISECONDS);
  4. client = null;
  5. }
  6. }

代码示例来源:origin: brianfrankcooper/YCSB

  1. @Override
  2. public void cleanup() throws DBException {
  3. if (client != null) {
  4. memcachedClient().shutdown(shutdownTimeoutMillis, MILLISECONDS);
  5. }
  6. }

代码示例来源:origin: ninjaframework/ninja

  1. @Dispose
  2. public void stop() {
  3. client.shutdown();
  4. }
  5. }

代码示例来源:origin: Netflix/EVCache

  1. public Map<SocketAddress, Map<String, String>> getStats(String cmd) {
  2. if(config.isRendInstance()) {
  3. List<InetSocketAddress> udsproxyInetSocketAddress = new ArrayList<InetSocketAddress>(memcachedNodesInZone.size());
  4. for(InetSocketAddress address : memcachedNodesInZone) {
  5. udsproxyInetSocketAddress.add(new InetSocketAddress(address.getHostName(), config.getUdsproxyMemcachedPort()));
  6. }
  7. MemcachedClient mc = null;
  8. try {
  9. mc = new MemcachedClient(connectionFactory, udsproxyInetSocketAddress);
  10. return mc.getStats(cmd);
  11. } catch(Exception ex) {
  12. } finally {
  13. if(mc != null) mc.shutdown();
  14. }
  15. return Collections.<SocketAddress, Map<String, String>>emptyMap();
  16. } else {
  17. return evcacheMemcachedClient.getStats(cmd);
  18. }
  19. }

代码示例来源:origin: magro/memcached-session-manager

  1. @Override
  2. public void shutdown() {
  3. _memcached.shutdown();
  4. }

代码示例来源:origin: magro/memcached-session-manager

  1. @AfterMethod
  2. public void tearDown() throws Exception {
  3. mc.shutdown();
  4. mc = null;
  5. if(!couchbaseProvided) {
  6. tearDownCouchbase();
  7. }
  8. _tomcat1.stop();
  9. }

代码示例来源:origin: magro/memcached-session-manager

  1. @AfterMethod
  2. public void tearDown() throws Exception {
  3. _client.shutdown();
  4. _httpClient.getConnectionManager().shutdown();
  5. _tomcat1.stop();
  6. _tomcat2.stop();
  7. _daemon.stop();
  8. if(_daemon2 != null)
  9. _daemon2.stop();
  10. }

代码示例来源:origin: magro/memcached-session-manager

  1. @AfterMethod
  2. public void tearDown() throws Exception {
  3. _client.shutdown(10, SECONDS);
  4. _daemon1.stop();
  5. _daemon2.stop();
  6. if(_daemon3 != null && _daemon3.isRunning()) {
  7. _daemon3.stop();
  8. }
  9. _tomcat1.stop();
  10. _tomcat2.stop();
  11. _httpClient.getConnectionManager().shutdown();
  12. _executor.shutdownNow();
  13. }

代码示例来源:origin: magro/memcached-session-manager

  1. private void setupCouchbaseClient() throws URISyntaxException, IOException {
  2. if(mc != null) {
  3. LOG.info("Closing existing couchbase client.");
  4. mc.shutdown();
  5. }
  6. final List<URI> uris = getURIs();
  7. LOG.info("Creating new couchbase client with uris " + uris);
  8. mc = new CouchbaseClient(uris, "default", "");
  9. }

代码示例来源:origin: com.google.code.maven-play-plugin.org.playframework/play

  1. @Override
  2. public void stop() {
  3. client.shutdown();
  4. }
  5. }

代码示例来源:origin: com.google.code.simple-spring-memcached/spymemcached

  1. /**
  2. * Shut down immediately.
  3. */
  4. public void shutdown() {
  5. shutdown(-1, TimeUnit.MILLISECONDS);
  6. }

代码示例来源:origin: com.amazonaws/elasticache-java-cluster-client

  1. /**
  2. * Shut down immediately.
  3. */
  4. @Override
  5. public void shutdown() {
  6. shutdown(-1, TimeUnit.MILLISECONDS);
  7. }

代码示例来源:origin: yyuu/jetty-nosql-memcached

  1. public boolean shutdown() throws KeyValueStoreClientException {
  2. if (_client != null) {
  3. _client.shutdown();
  4. _client = null;
  5. }
  6. return true;
  7. }

代码示例来源:origin: naver/arcus-java-client

  1. /**
  2. * Shut down immediately.
  3. */
  4. public void shutdown() {
  5. shutdown(-1, TimeUnit.MILLISECONDS);
  6. }

代码示例来源:origin: org.springframework.cloud/spring-cloud-aws-context

  1. @Override
  2. protected void destroyConnectionClient(MemcachedClient connectionClient) {
  3. connectionClient.shutdown(10, TimeUnit.SECONDS);
  4. }
  5. }

代码示例来源:origin: com.amazonaws/elasticache-java-cluster-client

  1. @Override
  2. public void destroy() throws Exception {
  3. if(shutdownTimeoutSeconds > 0) {
  4. client.shutdown(shutdownTimeoutSeconds, TimeUnit.SECONDS);
  5. } else {
  6. client.shutdown();
  7. }
  8. }

代码示例来源:origin: com.google.code.simple-spring-memcached/spymemcached

  1. public void connectionEstablished(SocketAddress sa, int reconnectCount) {
  2. if (authDescriptor != null) {
  3. if (authDescriptor.authThresholdReached()) {
  4. this.shutdown();
  5. }
  6. authMonitor.authConnection(mconn, opFact, authDescriptor, findNode(sa));
  7. }
  8. }

代码示例来源:origin: net.spy/spymemcached

  1. @Override
  2. public void connectionEstablished(SocketAddress sa, int reconnectCount) {
  3. if (authDescriptor != null) {
  4. if (authDescriptor.authThresholdReached()) {
  5. shutdown();
  6. }
  7. authMonitor.authConnection(mconn, opFact, authDescriptor, findNode(sa));
  8. }
  9. }

代码示例来源:origin: org.infinispan/infinispan-cli-server

  1. @AfterMethod
  2. public void release() {
  3. try {
  4. memcachedServer.stop();
  5. TestingUtil.killCacheManagers(cacheManager);
  6. memcachedClient.shutdown();
  7. } catch (Exception e) {
  8. e.printStackTrace();
  9. }
  10. }
  11. /* TODO: convert to new encoding

相关文章