From b2a65a6b63e8691b0101f4652705fab79dc26d99 Mon Sep 17 00:00:00 2001
From: Vitaly Takmazov
Date: Wed, 7 Dec 2016 12:37:43 +0300
Subject: juick-xmpp: refactoring

---
 .../src/main/java/com/juick/components/XMPPServer.java       | 12 +++++++++++-
 1 file changed, 11 insertions(+), 1 deletion(-)

(limited to 'juick-xmpp/src/main/java/com/juick/components/XMPPServer.java')

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);
+        }
+    }
+
 }
-- 
cgit v1.2.3