deux trois trucs

src/main/java/websockets/handlers/CuisineWebSocketReceiveHandler.java

@@ -0,0 +1,17 @@
+package websockets.handlers;
+
+import io.undertow.websockets.core.AbstractReceiveListener;
+import io.undertow.websockets.core.WebSocketChannel;
+
+public class CuisineReceiveListener extends AbstractReceiveListener {
+
+    public void register(WebSocketChannel iChannel)
+    {
+
+    }
+
+    public void unregister(WebSocketChannel iChannel)
+    {
+
+    }
+}

src/main/java/websockets/CuisineWebSocketChichatHandler.java → src/main/java/websockets/handlers/CuisineWebSocketWebSocketChichatHandler.java

@@ -1,4 +1,4 @@
-package websockets;
+package websockets.handlers;
 
 import io.undertow.websockets.core.AbstractReceiveListener;
 import io.undertow.websockets.core.BufferedTextMessage;
@@ -7,12 +7,12 @@ import io.undertow.websockets.core.WebSockets;
 
 import java.util.ArrayList;
 
-public class CuisineWebSocketChichatHandler extends AbstractReceiveListener {
+public class CuisineWebSocketChichatHandler extends CuisineReceiveListener {
 
     final int MAX_MESSAGES = 10;
     ArrayList<String> vMessageHistory;
 
-    protected CuisineWebSocketChichatHandler() {
+    public CuisineWebSocketChichatHandler() {
         vMessageHistory = new ArrayList<>();
     }
 
@@ -29,8 +29,23 @@ public class CuisineWebSocketChichatHandler extends AbstractReceiveListener {
         {
             vBuilder.append(vMessage+"\n");
         }
-        //Handle message on webSocket
+
         WebSockets.sendText(vBuilder.toString(), iChannel, null);
     }
 
+    public void register(WebSocketChannel iChannel)
+    {
+
+    }
+
+    public void unregister(WebSocketChannel iChannel)
+    {
+
+    }
+
+    protected void notifyOthers(String iMessages)
+    {
+        Websockets.sendText(iMessages)
+    }
+
 }

src/main/java/websockets/handlers/CuisineWebSocketWebSocketTemperatureHandler.java

@@ -0,0 +1,22 @@
+package websockets.handlers;
+
+
+import io.undertow.websockets.core.BufferedTextMessage;
+import io.undertow.websockets.core.WebSocketChannel;
+import io.undertow.websockets.core.WebSockets;
+import tcp.CuisineTCPServer;
+
+public class CuisineWebSocketWebSocketMessageHandler extends CuisineWebSocketReceiveHandler {
+
+    private CuisineTCPServer fTCPServer;
+
+    public CuisineWebSocketWebSocketMessageHandler(CuisineTCPServer iTCPServer) {
+        super();
+        fTCPServer = iTCPServer;
+    }
+
+    protected void onFullTextMessage(WebSocketChannel iChannel, BufferedTextMessage iTextMessage) {
+        //Handle message on webSocket
+        WebSockets.sendText(String.valueOf(fTCPServer.getCurrentTemperature()), iChannel, null);
+    }
+}