Krakatoa-Earth
/
KraSocketClient
3
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

added logger

master
Alex 2021-12-27 14:12:09 +01:00
parent ad762533a1
commit 79514cb5df
2 changed files with 8 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
src/main/java/earth/krakatao/KraSocketClient.java
View File

@ -11,13 +11,14 @@ import lombok.Getter;
public class KraSocketClient { public class KraSocketClient {
@Getter
public static final Logger logger = Logger.getLogger("KraSocketClient");
private KraSocketClientConfig kraSocketClientConfig; private KraSocketClientConfig kraSocketClientConfig;
@Getter @Getter
private final SocketClient socketClient; private final SocketClient socketClient;
private KraSocketClientEventInitiater kraSocketClientEventInitiater; private KraSocketClientEventInitiater kraSocketClientEventInitiater;
public static final Logger logger = Logger.getLogger(String.valueOf(KraSocketClient.class));
public KraSocketClient(KraSocketClientConfig kraSocketClientConfig, KraSocketClientEventInterface kraSocketClientEventInterface, KraSocketClientProtocol kraSocketClientProtocol) throws URISyntaxException { public KraSocketClient(KraSocketClientConfig kraSocketClientConfig, KraSocketClientEventInterface kraSocketClientEventInterface, KraSocketClientProtocol kraSocketClientProtocol) throws URISyntaxException {
this.kraSocketClientConfig = kraSocketClientConfig; this.kraSocketClientConfig = kraSocketClientConfig;

15
src/main/java/earth/krakatao/SocketClient.java
View File

@ -5,7 +5,6 @@ import earth.krakatao.protocol.KraSocketClientProtocolMessage;
import earth.krakatao.events.KraSocketClientEventInitiater; import earth.krakatao.events.KraSocketClientEventInitiater;
import java.net.URI; import java.net.URI;
import java.nio.ByteBuffer; import java.nio.ByteBuffer;
import java.util.logging.Logger;
import org.java_websocket.client.WebSocketClient; import org.java_websocket.client.WebSocketClient;
import org.java_websocket.handshake.ServerHandshake; import org.java_websocket.handshake.ServerHandshake;
@ -17,8 +16,6 @@ public class SocketClient extends WebSocketClient {
public SocketClient(URI serverUri, KraSocketClientEventInitiater kraSocketClientEventInitiater, KraSocketClientProtocol kraProtocol) { public SocketClient(URI serverUri, KraSocketClientEventInitiater kraSocketClientEventInitiater, KraSocketClientProtocol kraProtocol) {
super(serverUri); super(serverUri);
KraSocketClient.logger.info("socket client init");
this.kraSocketClientEventInitiater = kraSocketClientEventInitiater; this.kraSocketClientEventInitiater = kraSocketClientEventInitiater;
this.kraProtocol = kraProtocol; this.kraProtocol = kraProtocol;
} }
@ -32,12 +29,12 @@ public class SocketClient extends WebSocketClient {
@Override @Override
public void onOpen(ServerHandshake serverHandshake) { public void onOpen(ServerHandshake serverHandshake) {
this.kraSocketClientEventInitiater.callOnOpen(serverHandshake); this.kraSocketClientEventInitiater.callOnOpen(serverHandshake);
KraSocketClient.logger.info("open"); KraSocketClient.getLogger().info("connection open");
} }
@Override @Override
public void onMessage(String s) { public void onMessage(String s) {
System.out.println("message s: "+ s);
} }
@Override @Override
@ -45,19 +42,17 @@ public class SocketClient extends WebSocketClient {
KraSocketClientProtocolMessage kraProtocolMessage = new KraSocketClientProtocol().DecodeMessage(byteBuffer.array()); KraSocketClientProtocolMessage kraProtocolMessage = new KraSocketClientProtocol().DecodeMessage(byteBuffer.array());
this.kraSocketClientEventInitiater.callOnMessage(kraProtocolMessage); this.kraSocketClientEventInitiater.callOnMessage(kraProtocolMessage);
System.out.println("msg b:" + byteBuffer); KraSocketClient.getLogger().info("rec msg " + kraProtocolMessage);
} }
@Override @Override
public void onClose(int code, String reason, boolean remote) { public void onClose(int code, String reason, boolean remote) {
this.kraSocketClientEventInitiater.callOnClose(code, reason, remote); this.kraSocketClientEventInitiater.callOnClose(code, reason, remote);
System.out.println("close: " + code + " " +reason + " " +remote); KraSocketClient.logger.warning("connection closed. Code: " + code + " reason: " +reason + " remote: " +remote);
KraSocketClient.logger.info("close: " + code + " " +reason + " " +remote);
} }
@Override @Override
public void onError(Exception e) { public void onError(Exception e) {
System.out.println("Error: " + e); KraSocketClient.getLogger().warning("Err: " + e);
} }
} }