aboutsummaryrefslogtreecommitdiff
path: root/src/main/java/com/juick/xmpp/s2s/ConnectionListener.java
diff options
context:
space:
mode:
Diffstat (limited to 'src/main/java/com/juick/xmpp/s2s/ConnectionListener.java')
-rw-r--r--src/main/java/com/juick/xmpp/s2s/ConnectionListener.java7
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