From c469abc2a0cdef22b789c7b26ac05f261d21c870 Mon Sep 17 00:00:00 2001 From: Vitaly Takmazov Date: Mon, 2 Apr 2018 13:58:22 +0300 Subject: xmpp: router send s2s to server --- .../src/main/java/com/juick/server/xmpp/router/XMPPRouter.java | 9 ++++++--- 1 file changed, 6 insertions(+), 3 deletions(-) (limited to 'juick-server/src/main/java/com/juick') diff --git a/juick-server/src/main/java/com/juick/server/xmpp/router/XMPPRouter.java b/juick-server/src/main/java/com/juick/server/xmpp/router/XMPPRouter.java index 670962de..e5900977 100644 --- a/juick-server/src/main/java/com/juick/server/xmpp/router/XMPPRouter.java +++ b/juick-server/src/main/java/com/juick/server/xmpp/router/XMPPRouter.java @@ -1,5 +1,6 @@ package com.juick.server.xmpp.router; +import com.juick.server.XMPPServer; import com.juick.server.xmpp.s2s.BasicXmppSession; import org.slf4j.Logger; import org.slf4j.LoggerFactory; @@ -46,10 +47,12 @@ public class XMPPRouter implements StreamHandler { @Value("${router_port:5347}") private int routerPort; - @PostConstruct - public void init() { + private XMPPServer xmppServer; + @Inject + public XMPPRouter(XMPPServer xmppServer) { logger.info("component router initialized"); + this.xmppServer = xmppServer; service.submit(() -> { try { listener = new ServerSocket(routerPort); @@ -134,7 +137,7 @@ public class XMPPRouter implements StreamHandler { connOut.send(xml); return; } - logger.error("component unavailable: {}", hostname); + xmppServer.sendOut(Jid.of(hostname), xml); } -- cgit v1.2.3