update

Author: guFalcon

pom.xml

@@ -10,7 +10,7 @@
 
 <modelVersion>4.0.0</modelVersion>
 <artifactId>websocket-client</artifactId>
-<version>1.0.13</version>
+<version>1.0.14</version>
 <name>WebsocketClient</name>
 <packaging>jar</packaging>
 
@@ -25,7 +25,7 @@
 <dependency>
 <groupId>info.unterrainer.commons</groupId>
 <artifactId>oauth-token-manager</artifactId>
-<version>1.0.7</version>
+<version>1.0.10</version>
 </dependency>
 <dependency>
 <groupId>info.unterrainer.commons</groupId>

src/main/java/info/unterrainer/websocketclient/WebsocketConnection.java

@@ -2,6 +2,7 @@
 
 import java.io.IOException;
 import java.net.URI;
+import java.nio.ByteBuffer;
 import java.time.Duration;
 import java.util.List;
 import java.util.Map;
@@ -69,6 +70,20 @@ public Session awaitOpen(Duration timeoutInMillis) {
 }
 }
 
+/**
+ * Sends a ping message to the server to keep the connection alive.
+ */
+public void sendPing() {
+Session s = awaitOpen(Duration.ofMillis(5000L));
+try {
+s.getBasicRemote().sendPing(ByteBuffer.allocate(1));
+} catch (Exception e) {
+log.error("Error sending ping: ", e);
+throw new WebsocketSendingMessageException(String.format("Failed to send ping."), e);
+}
+log.debug("Sent ping");
+}
+
 public void send(String message) {
 Session s = awaitOpen(Duration.ofMillis(5000L));
 try {

src/main/java/info/unterrainer/websocketclient/WebsocketEndpoints.java

@@ -20,6 +20,7 @@ public WebsocketEndpoints(WebsocketConnection client) {
 @Override
 public void onOpen(Session session, EndpointConfig config) {
 client.sessionReady().complete(session);
+session.setMaxIdleTimeout(0L);
 log.info("Connected to server");
 if (client.onOpenHandler() != null) {
 try {