Method pingLoop

java/lib/src/main/java/io/github/ccxt/ws/WsClient.java:496–547

()

    // ─── Ping/Pong keep-alive ───

    private void pingLoop() {
        try {
            Thread.sleep(this.keepAlive);
            long now = System.currentTimeMillis();
            if (this.lastPong == 0) {
                this.lastPong = now;
            }

            while (this.keepAlive > 0 && this.isConnected) {
                now = System.currentTimeMillis();
                if (this.lastPong + this.keepAlive * this.maxPingPongMisses < now) {
                    this.onError(new RuntimeException(
                          getFormattedDate() + "Connection to " + this.url + " lost, no pong within " + this.keepAlive + "ms"));
                    break;
                }

                if (this.pingCallback != null) {
                    try {
                        Object pingResult = this.pingCallback.apply(this);
                        if (pingResult != null) {
                            this.send(pingResult);
                        } else {
                            // callback was not overriden we still need to send the frame
                            if (this.channel != null && this.channel.isActive()) {
                                if (this.verbose) {
                                    System.out.println(getFormattedDate() + "Ping Frame: " + this.lastPong);
                                }
                                this.channel.writeAndFlush(new PingWebSocketFrame());
                            }
                        }
                    } catch (Exception pingEx) {
                        this.onError(pingEx);
                        break;
                    }
                } else if (this.channel != null && this.channel.isActive()) {
                    if (this.verbose) {
                        System.out.println(getFormattedDate() + "Ping Frame: " + this.lastPong);
                    }
                    this.channel.writeAndFlush(new PingWebSocketFrame());
                }

                Thread.sleep(this.keepAlive);
            }
        } catch (InterruptedException e) {
            Thread.currentThread().interrupt();
        } catch (Exception e) {
            if (this.verbose) {
                System.err.println(getFormattedDate() + "PingLoop error: " + e.getMessage());
            }
            this.onError(e);
        }
    }

    // ─── Send ───