Compare commits
3 Commits
6e875e702b
...
368c67ce9f
Author | SHA1 | Date |
---|---|---|
|
368c67ce9f | |
|
1c4a5e532f | |
|
4e8d6c15be |
|
@ -32,12 +32,4 @@ public class KraSocketClient {
|
||||||
+ "&s="+ this.kraSocketClientConfig.getWebSocketServerName()),
|
+ "&s="+ this.kraSocketClientConfig.getWebSocketServerName()),
|
||||||
this.kraSocketClientEventInitiater, kraSocketClientProtocol);
|
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());
|
KraSocketClientProtocolMessage kraProtocolMessage = new KraSocketClientProtocol().DecodeMessage(byteBuffer.array());
|
||||||
|
|
||||||
this.kraSocketClientEventInitiater.callOnMessage(kraProtocolMessage);
|
this.kraSocketClientEventInitiater.callOnMessage(kraProtocolMessage);
|
||||||
KraSocketClient.getLogger().info("rec msg " + kraProtocolMessage);
|
|
||||||
}
|
}
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
|
|
|
@ -14,20 +14,20 @@ public class KraSocketClientEventInitiater {
|
||||||
}
|
}
|
||||||
|
|
||||||
public void callOnOpen(ServerHandshake serverHandshake) {
|
public void callOnOpen(ServerHandshake serverHandshake) {
|
||||||
for (KraSocketClientEventInterface testListener : listenerList) {
|
for (KraSocketClientEventInterface eventInterfaceListener : listenerList) {
|
||||||
testListener.kraSocketClientOnOpen(serverHandshake);
|
eventInterfaceListener.onOpen(serverHandshake);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
public void callOnMessage(KraSocketClientProtocolMessage kraProtocolMessage) {
|
public void callOnMessage(KraSocketClientProtocolMessage kraProtocolMessage) {
|
||||||
for (KraSocketClientEventInterface testListener : listenerList) {
|
for (KraSocketClientEventInterface eventInterfaceListener : listenerList) {
|
||||||
testListener.kraSocketClientOnMessage(kraProtocolMessage);
|
eventInterfaceListener.onMessage(kraProtocolMessage);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
public void callOnClose(int code, String reason, boolean remote) {
|
public void callOnClose(int code, String reason, boolean remote) {
|
||||||
for (KraSocketClientEventInterface testListener : listenerList) {
|
for (KraSocketClientEventInterface eventInterfaceListener : listenerList) {
|
||||||
testListener.kraSocketClientOnClose(code, reason, remote);
|
eventInterfaceListener.onClose(code, reason, remote);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
|
@ -5,9 +5,9 @@ import org.java_websocket.handshake.ServerHandshake;
|
||||||
|
|
||||||
public interface KraSocketClientEventInterface {
|
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