public static ProtocolException convertToMqttException()

in iothub/device/iot-device-client/src/main/java/com/microsoft/azure/sdk/iot/device/transport/mqtt/exceptions/PahoExceptionTranslator.java [23:80]
52 lines of code
23 McCabe index (conditional complexity)

    public static ProtocolException convertToMqttException(MqttException pahoException, String errorMessage)
    {
        switch (pahoException.getReasonCode())
        {
            case REASON_CODE_CLIENT_EXCEPTION:
                // MQTT Client encountered an exception, no connect code retrieved from service, so the reason
                // for this connection loss is in the mqttException cause
                if (pahoException.getCause() instanceof UnknownHostException
                        || pahoException.getCause() instanceof NoRouteToHostException
                        || pahoException.getCause() instanceof InterruptedException
                        || pahoException.getCause() instanceof SocketTimeoutException
                        || pahoException.getCause() instanceof SocketException)
                {
                    ProtocolException connectionException = new ProtocolException(errorMessage, pahoException);
                    connectionException.setRetryable(true);
                    return connectionException;
                }
                else
                {
                    return new ProtocolException(errorMessage, pahoException);
                }
            case REASON_CODE_INVALID_PROTOCOL_VERSION:
                return new MqttRejectedProtocolVersionException(errorMessage, pahoException);
            case REASON_CODE_INVALID_CLIENT_ID:
                return new MqttIdentifierRejectedException(errorMessage, pahoException);
            case REASON_CODE_BROKER_UNAVAILABLE:
                return new MqttServerUnavailableException(errorMessage, pahoException);
            case REASON_CODE_FAILED_AUTHENTICATION:
                return new MqttBadUsernameOrPasswordException(errorMessage, pahoException);
            case REASON_CODE_NOT_AUTHORIZED:
                return new MqttUnauthorizedException(errorMessage, pahoException);
            case REASON_CODE_SUBSCRIBE_FAILED:
            case REASON_CODE_CLIENT_NOT_CONNECTED:
            case REASON_CODE_TOKEN_INUSE:
            case REASON_CODE_CONNECTION_LOST:
            case REASON_CODE_SERVER_CONNECT_ERROR:
            case REASON_CODE_CLIENT_TIMEOUT:
            case REASON_CODE_WRITE_TIMEOUT:
            case REASON_CODE_MAX_INFLIGHT:
            case REASON_CODE_CONNECT_IN_PROGRESS:
                ProtocolException connectionException = new ProtocolException(errorMessage, pahoException);
                connectionException.setRetryable(true);
                return connectionException;
            default:
                if (pahoException.getReasonCode() >= UNDEFINED_MQTT_CONNECT_CODE_LOWER_BOUND && pahoException.getReasonCode() <= UNDEFINED_MQTT_CONNECT_CODE_UPPER_BOUND)
                {
                    //Mqtt connect codes 6 to 255 are reserved for future MQTT standard codes and are unused as of MQTT 3
                    //Codes_SRS_PahoExceptionTranslator_34_147: [When deriving the TransportException from the provided MqttException, this function shall map any connect codes between 6 and 255 inclusive to MqttUnexpectedErrorException.]
                    return new MqttUnexpectedErrorException(errorMessage, pahoException);
                }
                else
                {
                    //Mqtt connect code was not MQTT standard code, and was not a retryable exception as defined by Paho
                    //Codes_SRS_PahoExceptionTranslator_34_148: [When deriving the TransportException from the provided MqttException, this function shall map all other MqttExceptions to ProtocolException.]
                    return new ProtocolException(errorMessage, pahoException);
                }
        }
    }