Compare commits
3 Commits
6e875e702b
...
368c67ce9f
Author | SHA1 | Date |
---|---|---|
|
368c67ce9f | |
|
1c4a5e532f | |
|
4e8d6c15be |
|
@ -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";
|
||||
}
|
||||
}
|
||||
|
|
|
@ -47,7 +47,6 @@ public class SocketClient extends WebSocketClient {
|
|||
KraSocketClientProtocolMessage kraProtocolMessage = new KraSocketClientProtocol().DecodeMessage(byteBuffer.array());
|
||||
|
||||
this.kraSocketClientEventInitiater.callOnMessage(kraProtocolMessage);
|
||||
KraSocketClient.getLogger().info("rec msg " + kraProtocolMessage);
|
||||
}
|
||||
|
||||
@Override
|
||||
|
|
|
@ -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);
|
||||
}
|
||||
}
|
||||
}
|
||||
|
|
|
@ -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);
|
||||
}
|
||||
|
|
Loading…
Reference in New Issue