diff options
author | 2016-02-01 20:22:46 +0300 | |
---|---|---|
committer | 2016-02-01 20:22:46 +0300 | |
commit | 6cdc01aee58cddbfccefbf5def429d14367f6205 (patch) | |
tree | 3905dec2f4e0730b757e2f639508af7275d93524 /src/main/java/com/juick/xmpp/s2s/ConnectionListener.java | |
parent | eca85d4f4af0a3519acc8c82865127e7b558dbb5 (diff) |
refactoring
Diffstat (limited to 'src/main/java/com/juick/xmpp/s2s/ConnectionListener.java')
-rw-r--r-- | src/main/java/com/juick/xmpp/s2s/ConnectionListener.java | 7 |
1 files changed, 2 insertions, 5 deletions
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 |