public void connect()

in docker_images/java/wrapper/src/main/java/glue/ModuleGlue.java [86:121]

• 30 lines of code
• 5 McCabe index (conditional complexity)

    public void connect(String transportType, String connectionString, Certificate caCertificate, Handler<AsyncResult<ConnectResponse>> handler)
    {
        System.out.printf("Connect called with transport %s%n", transportType);

        IotHubClientProtocol protocol = this.transportFromString(transportType);
        if (protocol == null)
        {
            handler.handle(Future.failedFuture(new MainApiException(500, "invalid transport")));
            return;
        }

        try
        {
            String cert = caCertificate.getCert();
            ClientOptions.ClientOptionsBuilder clientOptionsBuilder = ClientOptions.builder();
            if (cert != null && !cert.isEmpty())
            {
                clientOptionsBuilder.sslContext(IotHubSSLContext.getSSLContextFromFile(cert));
            }

            ModuleClient client = new ModuleClient(connectionString, protocol, clientOptionsBuilder.build());

            client.open(true);

            this._clientCount++;
            String connectionId = "moduleClient_" + this._clientCount;
            this._map.put(connectionId, client);

            ConnectResponse cr = new ConnectResponse();
            cr.setConnectionId(connectionId);
            handler.handle(Future.succeededFuture(cr));
        } catch (Exception e)
        {
            handler.handle(Future.failedFuture(e));
        }
    }