From 6cdc01aee58cddbfccefbf5def429d14367f6205 Mon Sep 17 00:00:00 2001
From: Vitaly Takmazov
Date: Mon, 1 Feb 2016 20:22:46 +0300
Subject: refactoring

---
 src/main/java/com/juick/xmpp/s2s/ConnectionListener.java | 7 ++-----
 1 file changed, 2 insertions(+), 5 deletions(-)

(limited to 'src/main/java/com/juick/xmpp/s2s/ConnectionListener.java')

diff --git a/src/main/java/com/juick/xmpp/s2s/ConnectionListener.java b/src/main/java/com/juick/xmpp/s2s/ConnectionListener.java
index 982f2efc..de11f9a3 100644
--- a/src/main/java/com/juick/xmpp/s2s/ConnectionListener.java
+++ b/src/main/java/com/juick/xmpp/s2s/ConnectionListener.java
@@ -17,22 +17,19 @@ public class ConnectionListener implements Runnable {
 
     private static final Logger logger = Logger.getLogger(ConnectionListener.class.getName());
 
-    ExecutorService connectionPool;
-
     @Override
     public void run() {
         try {
-            connectionPool = Executors.newCachedThreadPool();
             final AsynchronousServerSocketChannel listener = AsynchronousServerSocketChannel.open();
             listener.bind(new InetSocketAddress(5269));
             logger.info("s2s listener ready");
             listener.accept(null, new CompletionHandler<AsynchronousSocketChannel, Object>() {
                 @Override
                 public void completed(AsynchronousSocketChannel result, Object attachment) {
-                    listener.accept(connectionPool, this);
+                    listener.accept(XMPPComponent.executorService, this);
                     ConnectionIn client = new ConnectionIn(result);
                     XMPPComponent.addConnectionIn(client);
-                    connectionPool.submit(client);
+                    XMPPComponent.executorService.submit(client);
                 }
 
                 @Override
-- 
cgit v1.2.3