public SaslClient createSaslClient()

in src/main/java/software/amazon/msk/auth/iam/internals/IAMSaslClient.java [233:250]

• 16 lines of code
• 3 McCabe index (conditional complexity)

        public SaslClient createSaslClient(String[] mechanisms,
                String authorizationId,
                String protocol,
                String serverName,
                Map<String, ?> props,
                CallbackHandler cbh) throws SaslException {
            String mechanismName = getMechanismNameForClassLoader(getClass().getClassLoader());

            for (String mechanism : mechanisms) {
                if (mechanismName.equals(mechanism)) {
                    return new IAMSaslClient(mechanism, cbh, serverName, new AWS4SignedPayloadGenerator());
                }
            }

            throw new SaslException(
                    "Requested mechanisms " + Arrays.asList(mechanisms) + " not supported. " +
                            "The supported mechanism is " + mechanismName);
        }