Compare commits

..

3 Commits

Author SHA1 Message Date
Alex 368c67ce9f removed unnecessary debug message 2021-12-27 14:32:32 +01:00
Alex 1c4a5e532f renamed methods 2021-12-27 14:32:13 +01:00
Alex 4e8d6c15be removed unnecessary methods 2021-12-27 14:30:25 +01:00
4 changed files with 10 additions and 19 deletions

View File

@ -32,12 +32,4 @@ public class KraSocketClient {
+ "&s="+ this.kraSocketClientConfig.getWebSocketServerName()),
this.kraSocketClientEventInitiater, kraSocketClientProtocol);
}
public void sendMsg(KraSocketClientProtocolMessage kraProtocolMessage) {
this.socketClient.SendMessage(kraProtocolMessage);
}
public String sendTest() {
return "hello";
}
}

View File

@ -47,13 +47,12 @@ public class SocketClient extends WebSocketClient {
KraSocketClientProtocolMessage kraProtocolMessage = new KraSocketClientProtocol().DecodeMessage(byteBuffer.array());
this.kraSocketClientEventInitiater.callOnMessage(kraProtocolMessage);
KraSocketClient.getLogger().info("rec msg " + kraProtocolMessage);
}
@Override
public void onClose(int code, String reason, boolean remote) {
this.kraSocketClientEventInitiater.callOnClose(code, reason, remote);
KraSocketClient.logger.warning("connection closed. Code: " + code + " reason: " +reason + " remote: " +remote);
KraSocketClient.logger.warning("connection closed. Code: " + code + " reason: " + reason + " remote: " + remote);
}
@Override

View File

@ -14,20 +14,20 @@ public class KraSocketClientEventInitiater {
}
public void callOnOpen(ServerHandshake serverHandshake) {
for (KraSocketClientEventInterface testListener : listenerList) {
testListener.kraSocketClientOnOpen(serverHandshake);
for (KraSocketClientEventInterface eventInterfaceListener : listenerList) {
eventInterfaceListener.onOpen(serverHandshake);
}
}
public void callOnMessage(KraSocketClientProtocolMessage kraProtocolMessage) {
for (KraSocketClientEventInterface testListener : listenerList) {
testListener.kraSocketClientOnMessage(kraProtocolMessage);
for (KraSocketClientEventInterface eventInterfaceListener : listenerList) {
eventInterfaceListener.onMessage(kraProtocolMessage);
}
}
public void callOnClose(int code, String reason, boolean remote) {
for (KraSocketClientEventInterface testListener : listenerList) {
testListener.kraSocketClientOnClose(code, reason, remote);
for (KraSocketClientEventInterface eventInterfaceListener : listenerList) {
eventInterfaceListener.onClose(code, reason, remote);
}
}
}

View File

@ -5,9 +5,9 @@ import org.java_websocket.handshake.ServerHandshake;
public interface KraSocketClientEventInterface {
void kraSocketClientOnMessage(KraSocketClientProtocolMessage kraProtocolMessage);
void onOpen(ServerHandshake serverHandshake);
void kraSocketClientOnOpen(ServerHandshake serverHandshake);
void onMessage(KraSocketClientProtocolMessage kraProtocolMessage);
void kraSocketClientOnClose(int code, String reason, boolean remote);
void onClose(int code, String reason, boolean remote);
}