public MqttAsyncClient getMqttAsyncClient()

in src/main/java/com/awslabs/aws/iot/websockets/BasicMqttOverWebsocketsProvider.java [68:74]

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

    public MqttAsyncClient getMqttAsyncClient(MqttClientConfig mqttClientConfig) throws MqttException, NoSuchAlgorithmException, InvalidKeyException, UnsupportedEncodingException {
        String mqttOverWebsocketsUri = getMqttOverWebsocketsUriString(mqttClientConfig.getOptionalMqttOverWebsocketsUriConfig());

        MemoryPersistence persistence = new MemoryPersistence();

        return new MqttAsyncClient(mqttOverWebsocketsUri, mqttClientConfig.getClientId().getClientId(), persistence);
    }