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/XMPPComponent.java | 11 +++++------
 1 file changed, 5 insertions(+), 6 deletions(-)

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

diff --git a/src/main/java/com/juick/xmpp/s2s/XMPPComponent.java b/src/main/java/com/juick/xmpp/s2s/XMPPComponent.java
index 3720d963..9be8c744 100644
--- a/src/main/java/com/juick/xmpp/s2s/XMPPComponent.java
+++ b/src/main/java/com/juick/xmpp/s2s/XMPPComponent.java
@@ -24,7 +24,7 @@ public class XMPPComponent implements ServletContextListener {
 
     private static final Logger LOGGER = Logger.getLogger(XMPPComponent.class.getName());
 
-    ExecutorService executorService;
+    public static final ExecutorService executorService = Executors.newCachedThreadPool();
 
     public static String HOSTNAME = null;
     public static String STATSFILE = null;
@@ -143,7 +143,7 @@ public class XMPPComponent implements ServletContextListener {
         }
 
         if (!haveAnyConn) {
-            new Thread(new ConnectionOut(hostname)).start();
+            XMPPComponent.executorService.submit(new ConnectionOut(hostname));
         }
     }
 
@@ -151,7 +151,6 @@ public class XMPPComponent implements ServletContextListener {
     public void contextInitialized(ServletContextEvent sce) {
 
         LOGGER.info("component initialized");
-        executorService = Executors.newSingleThreadExecutor();
         executorService.submit(() -> {
             Properties conf = new Properties();
             try {
@@ -167,9 +166,9 @@ public class XMPPComponent implements ServletContextListener {
                 childParsers.put(JuickMessage.XMLNS, new JuickMessage());
 
                 connRouter = new ConnectionRouter(componentName);
-                new Thread(connRouter).start();
-                new Thread(new ConnectionListener()).start();
-                new Thread(new CleaningUp()).start();
+                executorService.submit(connRouter);
+                executorService.submit(new ConnectionListener());
+                executorService.submit(new CleaningUp());
             } catch (IOException | ClassNotFoundException | SQLException e) {
                 LOGGER.log(Level.SEVERE, "XMPPComponent error", e);
             }
-- 
cgit v1.2.3