public void connect()

in src/main/java/com/awslabs/aws/iot/websockets/BasicMqttOverWebsocketsProvider.java [84:89]

• 6 lines of code
• 1 McCabe index (conditional complexity)

    public void connect(MqttClient mqttClient, ImmutableUsernamePassword usernamePassword) throws MqttException {
        MqttConnectOptions connOpts = new MqttConnectOptions();
        connOpts.setCleanSession(true);
        setUsernamePassword(usernamePassword, connOpts);
        mqttClient.connect(connOpts);
    }