src/main/java/earth/krakatao/KraSocketClient.java

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

src/main/java/earth/krakatao/SocketClient.java

@@ -47,12 +47,13 @@ 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

src/main/java/earth/krakatao/events/KraSocketClientEventInitiater.java

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

src/main/java/earth/krakatao/events/KraSocketClientEventInterface.java

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