Method createConnection

java/lib/src/main/java/io/github/ccxt/ws/WsClient.java:263–377

()

    }

    private void createConnection() {
        try {
            URI uri = new URI(this.url);
            String scheme = uri.getScheme();
            String host = uri.getHost();
            int port = uri.getPort();
            if (port == -1) {
                port = "wss".equalsIgnoreCase(scheme) ? 443 : 80;
            }
            boolean ssl = "wss".equalsIgnoreCase(scheme);

            final SslContext sslCtx;
            if (ssl) {
                var sslBuilder = SslContextBuilder.forClient();
                if (!this.validateServerSsl) {
                    sslBuilder.trustManager(InsecureTrustManagerFactory.INSTANCE);
                }
                sslCtx = sslBuilder.build();
            } else {
                sslCtx = null;
            }

            // Netty doesn't auto-attach User-Agent/Origin like browser/node WebSocket
            // libraries do, so we set them ourselves — caller-supplied values win.
            DefaultHttpHeaders requestHeaders = new DefaultHttpHeaders();
            boolean hasUserAgent = false;
            boolean hasOrigin = false;
            if (this.handshakeHeaders != null) {
                for (java.util.Map.Entry<String, String> e : this.handshakeHeaders.entrySet()) {
                    if (e.getKey() == null || e.getValue() == null) continue;
                    requestHeaders.add(e.getKey(), e.getValue());
                    if ("User-Agent".equalsIgnoreCase(e.getKey())) hasUserAgent = true;
                    if ("Origin".equalsIgnoreCase(e.getKey())) hasOrigin = true;
                }
            }
            if (!hasUserAgent) {
                requestHeaders.add("User-Agent", "ccxt/java");
            }
            if (!hasOrigin) {
                String origin = ("wss".equalsIgnoreCase(scheme) ? "https://" : "http://") + host;
                requestHeaders.add("Origin", origin);
            }

            WebSocketClientHandshaker handshaker = WebSocketClientHandshakerFactory.newHandshaker(
                    uri, WebSocketVersion.V13, null, true,
                    requestHeaders, 65536 * 100);

            final WsClientHandler handler = new WsClientHandler(handshaker, this);
            final int finalPort = port;

            Bootstrap bootstrap = new Bootstrap();
            bootstrap.group(SHARED_EVENT_LOOP)
                    .channel(NioSocketChannel.class)
                    .handler(new ChannelInitializer<SocketChannel>() {
                        @Override
                        protected void initChannel(SocketChannel ch) {
                            ChannelPipeline pipeline = ch.pipeline();