From 463d66fce7ef0dfea2afd537e9ef51b5ddf322da Mon Sep 17 00:00:00 2001 From: Vitaly Takmazov Date: Fri, 3 Feb 2017 12:54:35 +0300 Subject: juick-xmpp: handle stream errors --- juick-xmpp/src/main/java/com/juick/components/s2s/ConnectionIn.java | 6 ++++++ 1 file changed, 6 insertions(+) (limited to 'juick-xmpp/src/main/java/com/juick/components') diff --git a/juick-xmpp/src/main/java/com/juick/components/s2s/ConnectionIn.java b/juick-xmpp/src/main/java/com/juick/components/s2s/ConnectionIn.java index 8713aa03..1cd914c9 100644 --- a/juick-xmpp/src/main/java/com/juick/components/s2s/ConnectionIn.java +++ b/juick-xmpp/src/main/java/com/juick/components/s2s/ConnectionIn.java @@ -4,6 +4,7 @@ import com.juick.components.XMPPServer; import com.juick.xmpp.Iq; import com.juick.xmpp.Message; import com.juick.xmpp.Presence; +import com.juick.xmpp.extensions.StreamError; import com.juick.xmpp.utils.XmlUtils; import org.xmlpull.v1.XmlPullParser; import rocks.xmpp.addr.Jid; @@ -139,6 +140,11 @@ public class ConnectionIn extends Connection implements Runnable { } } else if (isSecured() && tag.equals("stream") && parser.getNamespace().equals(NS_STREAM)) { sendOpenStream(null, true); + } else if (tag.equals("error")) { + StreamError streamError = StreamError.parse(parser); + logger.warn("Stream error from {}: {}", streamID, streamError.getCondition()); + xmpp.removeConnectionIn(this); + closeConnection(); } else { String unhandledStanza = XmlUtils.parseToString(parser, true); logger.warn("Unhandled stanza from {}: {}", streamID, unhandledStanza); -- cgit v1.2.3