From bb164c441d110cf7bd4ce33dfab0ff184010647d Mon Sep 17 00:00:00 2001
From: Vitaly Takmazov
Date: Tue, 1 Dec 2015 13:51:43 +0300
Subject: PushComponent: executor service

---
 src/main/java/com/juick/push/PushComponent.java | 34 ++++++++++++++++---------
 1 file changed, 22 insertions(+), 12 deletions(-)

(limited to 'src/main/java/com/juick')

diff --git a/src/main/java/com/juick/push/PushComponent.java b/src/main/java/com/juick/push/PushComponent.java
index 6f857f59..a32e887c 100644
--- a/src/main/java/com/juick/push/PushComponent.java
+++ b/src/main/java/com/juick/push/PushComponent.java
@@ -48,6 +48,8 @@ import java.sql.SQLException;
 import java.util.ArrayList;
 import java.util.List;
 import java.util.Properties;
+import java.util.concurrent.ExecutorService;
+import java.util.concurrent.Executors;
 import java.util.logging.Level;
 import java.util.logging.Logger;
 
@@ -59,30 +61,38 @@ public class PushComponent implements ServletContextListener, Stream.StreamListe
 
     private static Logger logger = Logger.getLogger(PushComponent.class.getName());
 
+    private ExecutorService executorService;
     Connection sql;
     Socket socket;
     Stream xmpp;
     Sender GCMSender;
 
     @Override
-    public void contextInitialized(ServletContextEvent sce) {
+    public void contextInitialized(final ServletContextEvent sce) {
         logger.info("component initialized");
-        Properties conf = new Properties();
-        try {
-            conf.load(sce.getServletContext().getResourceAsStream("WEB-INF/push.conf"));
-            GCMSender = new Sender(conf.getProperty("gcm_key"));
+        executorService = Executors.newSingleThreadExecutor();
+        executorService.submit(new Runnable() {
+            @Override
+            public void run() {
+                Properties conf = new Properties();
+                try {
+                    conf.load(sce.getServletContext().getResourceAsStream("WEB-INF/push.conf"));
+                    GCMSender = new Sender(conf.getProperty("gcm_key"));
 
-            setupSql(conf.getProperty("mysql_host"), conf.getProperty("mysql_username"),
-                    conf.getProperty("mysql_password", ""), conf.getProperty("mysql_database", ""));
-            setupXmppComponent(new JID("", conf.getProperty("xmpp_jid"), ""), conf.getProperty("xmpp_host", "localhost"),
-                    Integer.parseInt(conf.getProperty("xmpp_port", "5347")), conf.getProperty("xmpp_password", ""));
-        } catch (IOException e) {
-            logger.log(Level.SEVERE, e.getMessage(), e);
-        }
+                    setupSql(conf.getProperty("mysql_host"), conf.getProperty("mysql_username"),
+                            conf.getProperty("mysql_password", ""), conf.getProperty("mysql_database", ""));
+                    setupXmppComponent(new JID("", conf.getProperty("xmpp_jid"), ""), conf.getProperty("xmpp_host", "localhost"),
+                            Integer.parseInt(conf.getProperty("xmpp_port", "5347")), conf.getProperty("xmpp_password", ""));
+                } catch (IOException e) {
+                    logger.log(Level.SEVERE, e.getMessage(), e);
+                }
+            }
+        });
     }
 
     @Override
     public void contextDestroyed(ServletContextEvent sce) {
+        executorService.shutdown();
         logger.info("component destroyed");
     }
 
-- 
cgit v1.2.3