aboutsummaryrefslogtreecommitdiff
path: root/src/main/java/com/juick/jabber/ws/WSData.java
diff options
context:
space:
mode:
Diffstat (limited to 'src/main/java/com/juick/jabber/ws/WSData.java')
-rw-r--r--src/main/java/com/juick/jabber/ws/WSData.java20
1 files changed, 10 insertions, 10 deletions
diff --git a/src/main/java/com/juick/jabber/ws/WSData.java b/src/main/java/com/juick/jabber/ws/WSData.java
index 3abc63d8..9ae98bcf 100644
--- a/src/main/java/com/juick/jabber/ws/WSData.java
+++ b/src/main/java/com/juick/jabber/ws/WSData.java
@@ -17,13 +17,16 @@ import java.nio.charset.Charset;
import java.security.MessageDigest;
import java.security.NoSuchAlgorithmException;
import java.util.Iterator;
+import java.util.logging.Level;
+import java.util.logging.Logger;
/**
*
* @author ugnich
*/
public class WSData implements Runnable {
-
+
+ private static final Logger logger = Logger.getLogger("Websockets");
static final String WEBSOCKET_GUID = "258EAFA5-E914-47DA-95CA-C5AB0DC85B11";
JdbcTemplate sql;
public Selector sel;
@@ -53,7 +56,7 @@ public class WSData implements Runnable {
SocketChannel sChannel = ssChannel.accept();
sChannel.configureBlocking(false);
sChannel.register(sel, SelectionKey.OP_READ);
- System.out.println(sChannel.socket().getRemoteSocketAddress().toString() + " ACCEPTED");
+ logger.info(sChannel.socket().getRemoteSocketAddress().toString() + " ACCEPTED");
} else if (selKey.isReadable()) {
SocketChannel sChannel = (SocketChannel) selKey.channel();
ByteBuffer buf = ByteBuffer.allocate(10240);
@@ -63,7 +66,6 @@ public class WSData implements Runnable {
buf.flip();
CharBuffer charbuf = Charset.forName("ISO-8859-1").decode(buf);
- System.out.println("DATA: " + charbuf.toString());
buf.rewind();
switch (buf.get(0)) {
@@ -89,7 +91,7 @@ public class WSData implements Runnable {
throw new IOException(sChannel.socket().getRemoteSocketAddress().toString() + " END OF STREAM");
}
} catch (IOException e) {
- System.err.println("WSData: " + e);
+ logger.log(Level.SEVERE, "websocket exception", e);
sChannel.socket().close();
sChannel.close();
selKey.cancel();
@@ -98,7 +100,7 @@ public class WSData implements Runnable {
}
}
} catch (Exception e) {
- System.err.println("WSData: " + e);
+ logger.log(Level.SEVERE, "websocket exception", e);
}
}
@@ -224,7 +226,7 @@ public class WSData implements Runnable {
sock.write(out);
if (responseCode == 101) {
- System.out.println(sock.socket().getRemoteSocketAddress().toString() + " HANDSHAKE (VUID = " + VUID + "; MID = " + MID + ")");
+ logger.info(sock.socket().getRemoteSocketAddress().toString() + " HANDSHAKE (VUID = " + VUID + "; MID = " + MID + ")");
} else {
throw new IOException(sock.socket().getRemoteSocketAddress().toString() + " " + responseCode);
}
@@ -236,7 +238,7 @@ public class WSData implements Runnable {
MessageDigest md = MessageDigest.getInstance("SHA-1");
return Base64.encode(md.digest(base.getBytes()));
} catch (NoSuchAlgorithmException e) {
- System.err.println("calcHeaderAccept: " + e);
+ logger.severe("calcHeaderAccept: " + e);
}
return "";
}
@@ -264,9 +266,7 @@ public class WSData implements Runnable {
public void updateSocketTS(SocketChannel sock) {
synchronized (Main.clients) {
- Iterator<SocketSubscribed> i = Main.clients.iterator();
- while (i.hasNext()) {
- SocketSubscribed s = i.next();
+ for (SocketSubscribed s : Main.clients) {
if (s.sock == sock) {
s.tsLastData = System.currentTimeMillis();
break;