public MqttClient getMqttClient()

in src/main/java/com/awslabs/aws/iot/websockets/BasicMqttOverWebsocketsProvider.java [59:65]

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

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

        MemoryPersistence persistence = new MemoryPersistence();

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