From 64824ed6dddf776ce3ed36fe96ffc300d4127e29 Mon Sep 17 00:00:00 2001
From: Vitaly Takmazov
Date: Mon, 8 Aug 2016 10:26:37 +0300
Subject: juick-ws: read component jids and ports from config

---
 .../juick/ws/components/CrosspostComponent.java    | 34 +++++++++-------------
 1 file changed, 14 insertions(+), 20 deletions(-)

(limited to 'juick-ws/src/main/java/com/juick/ws/components/CrosspostComponent.java')

diff --git a/juick-ws/src/main/java/com/juick/ws/components/CrosspostComponent.java b/juick-ws/src/main/java/com/juick/ws/components/CrosspostComponent.java
index ea397c28..977e0ed0 100644
--- a/juick-ws/src/main/java/com/juick/ws/components/CrosspostComponent.java
+++ b/juick-ws/src/main/java/com/juick/ws/components/CrosspostComponent.java
@@ -24,6 +24,7 @@ import com.juick.xmpp.Stream;
 import com.juick.xmpp.StreamComponent;
 import com.juick.xmpp.extensions.JuickMessage;
 import org.apache.commons.codec.binary.Base64;
+import org.apache.commons.lang3.math.NumberUtils;
 import org.apache.commons.lang3.tuple.Pair;
 import org.springframework.beans.factory.DisposableBean;
 import org.springframework.beans.factory.InitializingBean;
@@ -43,8 +44,6 @@ import java.net.URL;
 import java.net.URLEncoder;
 import java.security.Key;
 import java.util.UUID;
-import java.util.concurrent.ExecutorService;
-import java.util.concurrent.Executors;
 import java.util.logging.Level;
 import java.util.logging.Logger;
 
@@ -57,8 +56,6 @@ public class CrosspostComponent implements InitializingBean, DisposableBean, Str
 
     private static Logger logger = Logger.getLogger(CrosspostComponent.class.getName());
 
-    private ExecutorService executorService;
-
     public final static String TWITTERURL = "https://api.twitter.com/1.1/statuses/update.json";
     public final static String FBURL = "https://graph.facebook.com/me/feed";
     public final static String VKURL = "https://api.vk.com/method/wall.post";
@@ -73,23 +70,20 @@ public class CrosspostComponent implements InitializingBean, DisposableBean, Str
     @Override
     public void afterPropertiesSet() throws Exception {
         logger.info("component initialized");
-        executorService = Executors.newSingleThreadExecutor();
-        executorService.submit(() -> {
-            try {
-                twitter_consumer_key = env.getProperty("twitter_consumer_key", "");
-                twitter_consumer_secret = env.getProperty("twitter_consumer_secret", "");
-
-                setupSql(env.getProperty("datasource_driver", "com.mysql.jdbc.Driver"), env.getProperty("datasource_url", ""));
-                setupXmppComponent(env.getProperty("xmpp_password", ""));
-            } catch (Exception e) {
-                logger.log(Level.SEVERE, e.getMessage(), e);
-            }
-        });
+        try {
+            twitter_consumer_key = env.getProperty("twitter_consumer_key", "");
+            twitter_consumer_secret = env.getProperty("twitter_consumer_secret", "");
+
+            setupSql(env.getProperty("datasource_driver", "com.mysql.jdbc.Driver"), env.getProperty("datasource_url", ""));
+            setupXmppComponent(env.getProperty("crosspost_jid", "crosspost.juick.local"),
+                    env.getProperty("xmpp_password", ""), NumberUtils.toInt(env.getProperty("xmpp_port", ""), 5347));
+        } catch (Exception e) {
+            logger.log(Level.SEVERE, e.getMessage(), e);
+        }
     }
 
     @Override
     public void destroy() {
-        executorService.shutdown();
         logger.info("component destroyed");
     }
 
@@ -100,10 +94,10 @@ public class CrosspostComponent implements InitializingBean, DisposableBean, Str
         sql = new JdbcTemplate(dataSource);
     }
 
-    public void setupXmppComponent(String password) {
+    public void setupXmppComponent(String jid, String password, int port) {
         try {
-            Socket socket = new Socket("localhost", 5347);
-            xmpp = new StreamComponent(new JID("", "crosspost.juick.com", ""), socket.getInputStream(), socket.getOutputStream(), password);
+            Socket socket = new Socket("localhost", port);
+            xmpp = new StreamComponent(new JID(jid), socket.getInputStream(), socket.getOutputStream(), password);
             xmpp.addChildParser(new JuickMessage());
             xmpp.addListener((Stream.StreamListener) this);
             xmpp.addListener((Message.MessageListener) this);
-- 
cgit v1.2.3