aboutsummaryrefslogtreecommitdiff
path: root/juick-xmpp/src/main/java/com/juick/components/s2s
diff options
context:
space:
mode:
Diffstat (limited to 'juick-xmpp/src/main/java/com/juick/components/s2s')
-rw-r--r--juick-xmpp/src/main/java/com/juick/components/s2s/ConnectionIn.java12
1 files changed, 3 insertions, 9 deletions
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 ec996071..882cc2f7 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
@@ -72,6 +72,7 @@ public class ConnectionIn extends Connection implements Runnable {
String to = parser.getAttributeValue(null, "to");
logger.info("stream from {} to {} {} asking for dialback", dfrom, to, streamID);
if (dfrom.endsWith(xmpp.HOSTNAME) && (dfrom.equals(xmpp.HOSTNAME) || dfrom.endsWith("." + xmpp.HOSTNAME))) {
+ logger.warn("stream from {} is invalid", dfrom);
break;
}
if (to != null && to.equals(xmpp.HOSTNAME)) {
@@ -79,7 +80,8 @@ public class ConnectionIn extends Connection implements Runnable {
updateTsRemoteData();
xmpp.startDialback(dfrom, streamID, dbKey);
} else {
- throw new HostUnknownException("stream from " + dfrom + " " + streamID + " invalid to " + to);
+ logger.warn("stream from " + dfrom + " " + streamID + " invalid to " + to);
+ break;
}
} else if (tag.equals("verify") && parser.getNamespace().equals(NS_DB)) {
String vfrom = parser.getAttributeValue(null, "from");
@@ -149,8 +151,6 @@ public class ConnectionIn extends Connection implements Runnable {
logger.info("stream {} closed (dirty)", streamID);
xmpp.removeConnectionIn(this);
closeConnection();
- } catch (HostUnknownException e) {
- logger.warn(e.getMessage());
} catch (Exception e) {
logger.warn("stream {} error {}", streamID, e);
xmpp.removeConnectionIn(this);
@@ -201,10 +201,4 @@ public class ConnectionIn extends Connection implements Runnable {
}
return false;
}
-
- class HostUnknownException extends Exception {
- public HostUnknownException(String message) {
- super(message);
- }
- }
}