From d6fb4288688294d2f76325f14410db3091fea0fa Mon Sep 17 00:00:00 2001
From: Vitaly Takmazov
Date: Mon, 11 Jul 2016 12:25:03 +0300
Subject: logging

---
 .../java/com/juick/xmpp/s2s/ConnectionOut.java     | 26 +++++++++++-----------
 1 file changed, 13 insertions(+), 13 deletions(-)

(limited to 'juick-www/src/main/java/com/juick/xmpp/s2s/ConnectionOut.java')

diff --git a/juick-www/src/main/java/com/juick/xmpp/s2s/ConnectionOut.java b/juick-www/src/main/java/com/juick/xmpp/s2s/ConnectionOut.java
index 2552bfcd..24ed3363 100644
--- a/juick-www/src/main/java/com/juick/xmpp/s2s/ConnectionOut.java
+++ b/juick-www/src/main/java/com/juick/xmpp/s2s/ConnectionOut.java
@@ -58,7 +58,7 @@ public class ConnectionOut extends Connection implements Runnable {
 
     @Override
     public void run() {
-        LOGGER.info("STREAM TO " + to + " START");
+        logger.info("STREAM TO " + to + " START");
         try {
             socket = new Socket();
             socket.connect(DNSQueries.getServerAddress(to));
@@ -72,7 +72,7 @@ public class ConnectionOut extends Connection implements Runnable {
                 throw new Exception("STREAM TO " + to + " INVALID FIRST PACKET");
             }
 
-            LOGGER.info("STREAM TO " + to + " " + streamID + " OPEN");
+            logger.info("STREAM TO " + to + " " + streamID + " OPEN");
             xmpp.addConnectionOut(ConnectionOut.this);
             boolean xmppversionnew = parser.getAttributeValue(null, "version") != null;
             if (!xmppversionnew) {
@@ -90,16 +90,16 @@ public class ConnectionOut extends Connection implements Runnable {
                     String type = parser.getAttributeValue(null, "type");
                     if (type != null && type.equals("valid")) {
                         streamReady = true;
-                        LOGGER.info("STREAM TO " + to + " " + streamID + " READY");
+                        logger.info("STREAM TO " + to + " " + streamID + " READY");
 
                         String cache = xmpp.getFromCache(to);
                         if (cache != null) {
-                            LOGGER.info("STREAM TO " + to + " " + streamID + " SENDING CACHE");
+                            logger.info("STREAM TO " + to + " " + streamID + " SENDING CACHE");
                             sendStanza(cache);
                         }
 
                     } else {
-                        LOGGER.info("STREAM TO " + to + " " + streamID + " DIALBACK FAIL");
+                        logger.info("STREAM TO " + to + " " + streamID + " DIALBACK FAIL");
                     }
                     XmlUtils.skip(parser);
                 } else if (tag.equals("verify") && parser.getNamespace().equals(NS_DB)) {
@@ -116,7 +116,7 @@ public class ConnectionOut extends Connection implements Runnable {
                 } else if (tag.equals("features") && parser.getNamespace().equals(NS_STREAM)) {
                     StreamFeatures features = StreamFeatures.parse(parser);
                     if (!isSecured() && features.STARTTLS >= 0 && !xmpp.brokenSSLhosts.contains(to)) {
-                        System.out.println("STREAM TO " + to + " " + streamID + " SECURING");
+                        logger.info("STREAM TO " + to + " " + streamID + " SECURING");
                         sendStanza("<starttls xmlns=\"" + NS_TLS + "\" />");
                     } else {
                         processDialback();
@@ -127,11 +127,11 @@ public class ConnectionOut extends Connection implements Runnable {
                                 socket.getPort(), true);
                         ((SSLSocket) socket).startHandshake();
                         setSecured(true);
-                        System.out.println("STREAM " + streamID + " SECURED");
+                        logger.info("STREAM " + streamID + " SECURED");
                         restartParser();
                         sendOpenStream();
                     } catch (SSLException sex) {
-                        LOGGER.log(Level.SEVERE, String.format("s2s ssl error: %s %s", to, streamID), sex);
+                        logger.log(Level.SEVERE, String.format("s2s ssl error: %s %s", to, streamID), sex);
                         sendStanza("<failed xmlns\"" + NS_TLS + "\" />");
                         xmpp.removeConnectionOut(this);
                         closeConnection();
@@ -139,19 +139,19 @@ public class ConnectionOut extends Connection implements Runnable {
                 } else if (isSecured() && tag.equals("stream") && parser.getNamespace().equals(NS_STREAM)) {
                     streamID = parser.getAttributeValue(null, "id");
                 } else {
-                    LOGGER.info("STREAM TO " + to + " " + streamID + ": " + XmlUtils.parseToString(parser, true));
+                    logger.info("STREAM TO " + to + " " + streamID + ": " + XmlUtils.parseToString(parser, true));
                 }
             }
 
-            LOGGER.warning("STREAM TO " + to + " " + streamID + " FINISHED");
+            logger.warning("STREAM TO " + to + " " + streamID + " FINISHED");
             xmpp.removeConnectionOut(ConnectionOut.this);
             closeConnection();
         } catch (EOFException | SocketException eofex) {
-            LOGGER.info(String.format("STREAM %s %s CLOSED (dirty)", to, streamID));
+            logger.info(String.format("STREAM %s %s CLOSED (dirty)", to, streamID));
             xmpp.removeConnectionOut(ConnectionOut.this);
             closeConnection();
         } catch (Exception e) {
-            LOGGER.log(Level.SEVERE, String.format("s2s out exception: %s %s", to, streamID), e);
+            logger.log(Level.SEVERE, String.format("s2s out exception: %s %s", to, streamID), e);
             xmpp.removeConnectionOut(ConnectionOut.this);
             closeConnection();
         }
@@ -161,7 +161,7 @@ public class ConnectionOut extends Connection implements Runnable {
         try {
             sendStanza("<db:verify from='" + xmpp.HOSTNAME + "' to='" + to + "' id='" + sid + "'>" + key + "</db:verify>");
         } catch (IOException e) {
-            LOGGER.log(Level.WARNING, "STREAM TO " + to + " " + streamID + " ERROR", e);
+            logger.log(Level.WARNING, "STREAM TO " + to + " " + streamID + " ERROR", e);
         }
     }
 }
-- 
cgit v1.2.3