public void keepalive(String nodeId) {
        TurmsConnection connection = nodeIdToConnection.get(nodeId);
        if (connection == null) {
            throw new RuntimeException(
                    "Received a keepalive request from a non-connected node: "
                            + nodeId);
        }
        connection.setLastKeepaliveTimestampNanos(System.nanoTime());
    }
Use supplier rather than just listener so that we can bind each generated listener to a
specific TcpConnection to make logic simple
turms-server-common/src/main/java/im/turms/server/common/infra/cluster/service/connection/ConnectionService.java