#9, shutdown method

C2B2 · Jul 2, 2013 · 09d0be0 · 09d0be0
1 parent be23149
commit 09d0be0
Showing 1 changed file with 10 additions and 3 deletions.
diff --git a/coherence-memcached-server/src/main/java/uk/co/c2b2/memcached/server/MemcachedServer.java b/coherence-memcached-server/src/main/java/uk/co/c2b2/memcached/server/MemcachedServer.java
@@ -85,6 +85,11 @@ public void bootStrap() {
         if (myLogger.isLoggable(Level.INFO))
           myLogger.info("Bootstrapped Memcached server on port " + myPort + " backed by named cache " + myNamedCache);
     }
+
+    public void shutdown() {
+        channelFactory.releaseExternalResources();
+        CacheFactory.shutdown();
+    }
 
     public NamedCache getCache() {
         return myCache;
@@ -98,16 +103,18 @@ void bootStrapCache() {
     void bootStrapSocketServer() {
         OperationFactory operationFactory = new OperationFactory(myCache);
 
-        ChannelFactory factory = new NioServerSocketChannelFactory(Executors.newCachedThreadPool(),Executors.newCachedThreadPool());
-        ServerBootstrap bootstrap = new ServerBootstrap(factory);
+        channelFactory = new NioServerSocketChannelFactory(Executors.newCachedThreadPool(),Executors.newCachedThreadPool());
+        ServerBootstrap bootstrap = new ServerBootstrap(channelFactory);
         bootstrap.setPipelineFactory(new MemcachedPipelineFactory(operationFactory));
         bootstrap.setOption("child.tcpNoDelay", true);
         bootstrap.setOption("child.keepAlive", true);
         bootstrap.bind(new InetSocketAddress(myPort));
     }
-    
+
     private Logger myLogger = Logger.getLogger(this.getClass().getName());
     private int myPort;
     private String myNamedCache;
     private NamedCache myCache;
+
+    private ChannelFactory channelFactory;
 }