diff options
Diffstat (limited to 'juick-server/src/test/java/com/juick/server/tests/WebsocketClientHandler.java')
-rw-r--r-- | juick-server/src/test/java/com/juick/server/tests/WebsocketClientHandler.java | 36 |
1 files changed, 0 insertions, 36 deletions
diff --git a/juick-server/src/test/java/com/juick/server/tests/WebsocketClientHandler.java b/juick-server/src/test/java/com/juick/server/tests/WebsocketClientHandler.java deleted file mode 100644 index ae92ccf0..00000000 --- a/juick-server/src/test/java/com/juick/server/tests/WebsocketClientHandler.java +++ /dev/null @@ -1,36 +0,0 @@ -package com.juick.server.tests; - -import org.springframework.web.socket.TextMessage; -import org.springframework.web.socket.WebSocketSession; -import org.springframework.web.socket.handler.TextWebSocketHandler; - -import java.io.IOException; -import java.util.concurrent.CountDownLatch; - -class WebsocketClientHandler extends TextWebSocketHandler { - private final CountDownLatch latch; - private WebSocketSession session; - private String lastMessage; - public WebsocketClientHandler(CountDownLatch latch) { - this.latch = latch; - } - @Override - public void afterConnectionEstablished(WebSocketSession session) throws IOException { - this.session = session; - session.sendMessage(new TextMessage("PING")); - } - - @Override - protected void handleTextMessage(WebSocketSession session, TextMessage message) { - this.lastMessage = message.getPayload(); - latch.countDown(); - } - - public WebSocketSession getSession() { - return session; - } - - public String getLastMessage() { - return lastMessage; - } -} |