Method client

java/lib/src/main/java/io/github/ccxt/Exchange.java:1636–1682

(Object url2)

    // ─── WebSocket Bridge (matches C# Exchange.WsBridge.cs) ───

    @SuppressWarnings("unchecked")
    public Client client(Object url2) {
        String url = url2.toString();
        return ((java.util.concurrent.ConcurrentHashMap<String, Client>) this.clients)
                .computeIfAbsent(url, u -> {
                    Object ws = this.safeValue(this.options, "ws", new java.util.HashMap<String, Object>());
                    Object wsOptions = this.safeValue(ws, "options", new java.util.HashMap<String, Object>());
                    long keepAlive = 30000;
                    Object keepAliveObj = this.safeValue(wsOptions, "keepAlive", null);
                    if (keepAliveObj instanceof Number n) keepAlive = n.longValue();
                    boolean decompressBin = true;
                    Object decompressObj = this.safeValue(this.options, "decompressBinary", null);
                    if (decompressObj instanceof Boolean b) decompressBin = b;

                    var result = this.checkWsProxySettings();
                    String proxy = null;
                    if (result instanceof java.util.List<?> proxies) {
                        for (Object p : proxies) {
                            if (p != null) { proxy = p.toString(); break; }
                        }
                    }

                    Client created = new Client(u, proxy,
                            (client, msg) -> this.handleMessage((Client) client, msg),
                            (client) -> this.ping((Client) client),
                            (client, err) -> this.onClose((Client) client, err),
                            (client, err) -> this.onError((Client) client, err),
                            this.verbose, keepAlive, decompressBin,
                            this.validateServerSsl);

                    // Forward options.ws.options.headers to the upgrade request — required
                    // by exchanges that gate on User-Agent (weex) or send custom headers.
                    Object headers = this.safeValue(wsOptions, "headers", null);
                    if (headers instanceof java.util.Map<?, ?> m) {
                        java.util.Map<String, String> hh = new java.util.HashMap<>();
                        for (java.util.Map.Entry<?, ?> e : m.entrySet()) {
                            if (e.getKey() == null || e.getValue() == null) continue;
                            hh.put(e.getKey().toString(), e.getValue().toString());
                        }
                        if (!hh.isEmpty()) {
                            created.handshakeHeaders = hh;
                        }
                    }

                    return created;
                });
    }

    public CompletableFuture<Object> watch(Object url, Object messageHash2, Object message, Object subscribeHash2, Object subscription) {
        String messageHash = messageHash2.toString();