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 {