juick-xmpp: refactoring

1 files changed, 11 insertions, 1 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 c51810a5..caa4c200 100644
--- a/juick-xmpp/src/main/java/com/juick/components/XMPPServer.java
+++ b/juick-xmpp/src/main/java/com/juick/components/XMPPServer.java
@@ -209,7 +209,7 @@ public class XMPPServer implements AutoCloseable {
             try {
                 connOut.sendStanza(xml);
             } catch (IOException e) {
-                logger.warn("STREAM TO {} {} ERROR: {}",
+                logger.warn("stream to {} {} error: {}",
                         connOut.to, connOut.streamID, e);
             }
             return;
@@ -256,4 +256,14 @@ public class XMPPServer implements AutoCloseable {
         return outCache;
     }
 
+    public void startDialback(String from, String streamId, String dbKey) throws Exception {
+        ConnectionOut c = getConnectionOut(from, false);
+        if (c != null) {
+            c.sendDialbackVerify(streamId, dbKey);
+        } else {
+            c = new ConnectionOut(this, from, streamId, dbKey);
+            service.submit(c);
+        }
+    }
+
 }