aboutsummaryrefslogtreecommitdiff
diff options
context:
space:
mode:
-rw-r--r--juick-xmpp/src/main/java/com/juick/components/XMPPServer.java13
1 files changed, 10 insertions, 3 deletions
diff --git a/juick-xmpp/src/main/java/com/juick/components/XMPPServer.java b/juick-xmpp/src/main/java/com/juick/components/XMPPServer.java
index 29d57d53..de9476a8 100644
--- a/juick-xmpp/src/main/java/com/juick/components/XMPPServer.java
+++ b/juick-xmpp/src/main/java/com/juick/components/XMPPServer.java
@@ -18,6 +18,7 @@
package com.juick.components;
import com.juick.components.s2s.*;
+import com.juick.service.UserService;
import com.juick.xmpp.extensions.JuickMessage;
import com.juick.xmpp.extensions.StreamError;
import org.slf4j.Logger;
@@ -37,9 +38,7 @@ import javax.xml.bind.Unmarshaller;
import javax.xml.stream.XMLStreamException;
import javax.xml.stream.XMLStreamWriter;
import java.io.*;
-import java.net.ServerSocket;
-import java.net.Socket;
-import java.net.SocketException;
+import java.net.*;
import java.security.KeyStore;
import java.security.KeyStoreException;
import java.security.SecureRandom;
@@ -100,6 +99,8 @@ public class XMPPServer implements ConnectionListener, AutoCloseable {
@Inject
private BasicXmppSession session;
+ @Inject
+ private UserService userService;
@PostConstruct
public void init() throws KeyStoreException {
@@ -252,6 +253,12 @@ public class XMPPServer implements ConnectionListener, AutoCloseable {
addConnectionOut(socket, streamServerDialback);
streamServerDialback.addChildParser(new JuickMessage());
streamServerDialback.connect();
+ } catch (UnknownHostException | ConnectException e) {
+ userService.getActiveJIDs().stream().filter(j -> Jid.of(j).getDomain().equals(to))
+ .forEach(j -> {
+ userService.setActiveStatusForJID(j, UserService.ActiveStatus.Inactive);
+ logger.info("{} is inactive now", j);
+ });
} catch (Exception e) {
logger.error("s2s out error", e);
}