1 files changed, 6 insertions, 13 deletions
diff --git a/src/main/java/com/juick/server/XMPPConnection.java b/src/main/java/com/juick/server/XMPPConnection.java
index dfbe92d5..c4816478 100644
--- a/src/main/java/com/juick/server/XMPPConnection.java
+++ b/src/main/java/com/juick/server/XMPPConnection.java
@@ -24,7 +24,6 @@ import com.juick.service.component.*;
 import com.juick.model.CommandResult;
 import com.juick.server.xmpp.iq.MessageQuery;
 import com.juick.server.xmpp.s2s.BasicXmppSession;
-import com.juick.server.xmpp.s2s.StanzaListener;
 import com.juick.service.*;
 import com.juick.util.MessageUtils;
 import org.apache.commons.codec.digest.DigestUtils;
@@ -81,14 +80,12 @@ import java.util.concurrent.ExecutorService;
 /**
  * @author ugnich
  */
-public class XMPPConnection implements StanzaListener, NotificationListener {
+public class XMPPConnection implements NotificationListener {
 
     private static final Logger logger = LoggerFactory.getLogger("com.juick.server.xmpp");
 
     private ExternalComponent router;
     @Inject
-    private XMPPServer xmpp;
-    @Inject
     private CommandsManager commandsManager;
     @Value("${xmppbot_jid:juick@localhost}")
     private Jid jid;
@@ -96,6 +93,8 @@ public class XMPPConnection implements StanzaListener, NotificationListener {
     private String componentName;
     @Value("${component_port:5347}")
     private int componentPort;
+    @Value("${component_host:localhost}")
+    private String componentHost;
     @Value("${xmpp_password:secret}")
     private String password;
     @Value("${upload_tmp_dir:#{systemEnvironment['TEMP'] ?: '/tmp'}}")
@@ -110,7 +109,7 @@ public class XMPPConnection implements StanzaListener, NotificationListener {
     @Inject
     private BasicXmppSession session;
     @Inject
-    private ExecutorService service;
+    private ExecutorService executorService;
     @Value("${service_user:juick}")
     private String serviceUsername;
     @Inject
@@ -121,8 +120,7 @@ public class XMPPConnection implements StanzaListener, NotificationListener {
     @PostConstruct
     public void init() {
         logger.info("stream router start connecting to {}", componentPort);
-        xmpp.addStanzaListener(this);
-        router = ExternalComponent.create(componentName, password, session.getConfiguration(), "localhost", componentPort);
+        router = ExternalComponent.create(componentName, password, session.getConfiguration(), componentHost, componentPort);
         ServiceDiscoveryManager serviceDiscoveryManager = router.getManager(ServiceDiscoveryManager.class);
         serviceDiscoveryManager.addIdentity(Identity.clientBot().withName("Juick"));
         EntityCapabilitiesManager entityCapabilitiesManager = router.getManager(EntityCapabilitiesManager.class);
@@ -259,7 +257,7 @@ public class XMPPConnection implements StanzaListener, NotificationListener {
         router.addInboundPresenceListener(event -> {
             incomingPresence(event.getPresence());
         });
-        service.submit(() -> {
+        executorService.submit(() -> {
             try {
                 router.connect();
             } catch (XmppException e) {
@@ -644,11 +642,6 @@ public class XMPPConnection implements StanzaListener, NotificationListener {
         return null;
     }
 
-    @Override
-    public void stanzaReceived(Stanza xmlValue) {
-        router.send(xmlValue);
-    }
-
     private void broadcastPresence(Presence.Type type) {
         Presence presence = new Presence();
         presence.setFrom(jid);