test_class.declarator: KNOWN_PLAIN_SASL_MECHANISM = "PLAIN"
test_class.modifier: private static final
test_class.original_string: private static final String KNOWN_PLAIN_SASL_MECHANISM = "PLAIN";
test_class.type: String
test_class.var_name: KNOWN_PLAIN_SASL_MECHANISM
test_class.declarator: KNOWN_SHA256_SASL_MECHANISM = "SCRAM-SHA-256"
test_class.modifier: private static final
test_class.original_string: private static final String KNOWN_SHA256_SASL_MECHANISM = "SCRAM-SHA-256";
test_class.type: String
test_class.var_name: KNOWN_SHA256_SASL_MECHANISM
test_class.declarator: KNOWN_SHA512_SASL_MECHANISM = "SCRAM-SHA-512"
test_class.modifier: private static final
test_class.original_string: private static final String KNOWN_SHA512_SASL_MECHANISM = "SCRAM-SHA-512";
test_class.type: String
test_class.var_name: KNOWN_SHA512_SASL_MECHANISM
test_class.declarator: KNOWN_UNSUPPORTED_GSSAPI_SASL_MECHANISM = "GSSAPI"
test_class.modifier: private static final
test_class.original_string: private static final String KNOWN_UNSUPPORTED_GSSAPI_SASL_MECHANISM = "GSSAPI";
test_class.type: String
test_class.var_name: KNOWN_UNSUPPORTED_GSSAPI_SASL_MECHANISM
test_class.declarator: KNOWN_UNSUPPORTED_OAUTHBEARER_SASL_MECHANISM = "OAUTHBEARER"
test_class.modifier: private static final
test_class.original_string: private static final String KNOWN_UNSUPPORTED_OAUTHBEARER_SASL_MECHANISM = "OAUTHBEARER";
test_class.type: String
test_class.var_name: KNOWN_UNSUPPORTED_OAUTHBEARER_SASL_MECHANISM
test_class.declarator: UNKNOWN_SASL_MECHANISM = "ANYTHING-ELSE"
test_class.modifier: private static final
test_class.original_string: private static final String UNKNOWN_SASL_MECHANISM = "ANYTHING-ELSE";
test_class.type: String
test_class.var_name: UNKNOWN_SASL_MECHANISM
test_class.declarator: HEADERS = DittoHeaders.empty()
test_class.modifier: private static final
test_class.original_string: private static final DittoHeaders HEADERS = DittoHeaders.empty();
test_class.type: DittoHeaders
test_class.var_name: HEADERS
test_class.declarator: DEFAULT_HOST = "localhost:1883"
test_class.modifier: private static final
test_class.original_string: private static final String DEFAULT_HOST = "localhost:1883";
test_class.type: String
test_class.var_name: DEFAULT_HOST
test_class.declarator: KNOWN_USER = "knownUser"
test_class.modifier: private static final
test_class.original_string: private static final String KNOWN_USER = "knownUser";
test_class.type: String
test_class.var_name: KNOWN_USER
test_class.declarator: KNOWN_PASSWORD = "knownPassword"
test_class.modifier: private static final
test_class.original_string: private static final String KNOWN_PASSWORD = "knownPassword";
test_class.type: String
test_class.var_name: KNOWN_PASSWORD
test_class.declarator: defaultSpecificConfig
test_class.modifier: private static
test_class.original_string: private static Map<String, String> defaultSpecificConfig;
test_class.type: Map<String, String>
test_class.var_name: defaultSpecificConfig
test_class.declarator: underTest
test_class.modifier: private
test_class.original_string: private KafkaAuthenticationSpecificConfig underTest;
test_class.type: KafkaAuthenticationSpecificConfig
test_class.var_name: underTest
test_class.file: services/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/kafka/KafkaAuthenticationSpecificConfigTest.java
test_class.identifier: KafkaAuthenticationSpecificConfigTest
test_case.body: @Test
      public void shouldBeValidIfContainsNoSaslMechanism() {
          assertThat(underTest.isValid(getConnectionWithSaslMechanism(null))).isTrue();
      }
test_case.class_method_signature: KafkaAuthenticationSpecificConfigTest.shouldBeValidIfContainsNoSaslMechanism()
test_case.full_signature: @Test public void shouldBeValidIfContainsNoSaslMechanism()
test_case.identifier: shouldBeValidIfContainsNoSaslMechanism
test_case.invocations: isTrue assertThat isValid getConnectionWithSaslMechanism
test_case.modifiers: @Test public
test_case.parameters: ()
test_case.return: void
test_case.signature: void shouldBeValidIfContainsNoSaslMechanism()
focal_class.declarator: SPECIFIC_CONFIG_SASL_MECHANISM_KEY = "saslMechanism"
focal_class.modifier: private static final
focal_class.original_string: private static final String SPECIFIC_CONFIG_SASL_MECHANISM_KEY = "saslMechanism";
focal_class.type: String
focal_class.var_name: SPECIFIC_CONFIG_SASL_MECHANISM_KEY
focal_class.declarator: JAAS_CONFIG_TEMPLATE = "%s required username=\"%s\" password=\"%s\";"
focal_class.modifier: @SuppressWarnings("squid:S2068")
      private static final
focal_class.original_string: @SuppressWarnings("squid:S2068")
      private static final String JAAS_CONFIG_TEMPLATE = "%s required username=\"%s\" password=\"%s\";";
focal_class.type: String
focal_class.var_name: JAAS_CONFIG_TEMPLATE
focal_class.declarator: PLAIN_SASL_MECHANISM = "PLAIN"
focal_class.modifier: private static final
focal_class.original_string: private static final String PLAIN_SASL_MECHANISM = "PLAIN";
focal_class.type: String
focal_class.var_name: PLAIN_SASL_MECHANISM
focal_class.declarator: DEFAULT_SASL_MECHANISM = PLAIN_SASL_MECHANISM
focal_class.modifier: private static final
focal_class.original_string: private static final String DEFAULT_SASL_MECHANISM = PLAIN_SASL_MECHANISM;
focal_class.type: String
focal_class.var_name: DEFAULT_SASL_MECHANISM
focal_class.declarator: SASL_MECHANISMS_WITH_LOGIN_MODULE = new HashMap<>()
focal_class.modifier: private static final
focal_class.original_string: private static final Map<String, String> SASL_MECHANISMS_WITH_LOGIN_MODULE = new HashMap<>();
focal_class.type: Map<String, String>
focal_class.var_name: SASL_MECHANISMS_WITH_LOGIN_MODULE
focal_class.declarator: instance
focal_class.modifier: @Nullable private static
focal_class.original_string: @Nullable private static KafkaAuthenticationSpecificConfig instance;
focal_class.type: KafkaAuthenticationSpecificConfig
focal_class.var_name: instance
focal_class.file: services/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/kafka/KafkaAuthenticationSpecificConfig.java
focal_class.identifier: KafkaAuthenticationSpecificConfig
focal_class.interfaces: implements KafkaSpecificConfig
focal_class.class_method_signature: KafkaAuthenticationSpecificConfig.KafkaAuthenticationSpecificConfig()
focal_class.full_signature: private  KafkaAuthenticationSpecificConfig()
focal_class.identifier: KafkaAuthenticationSpecificConfig
focal_class.modifiers: private
focal_class.parameters: ()
focal_class.signature:  KafkaAuthenticationSpecificConfig()
focal_class.class_method_signature: KafkaAuthenticationSpecificConfig.getInstance()
focal_class.full_signature: public static KafkaAuthenticationSpecificConfig getInstance()
focal_class.identifier: getInstance
focal_class.modifiers: public static
focal_class.parameters: ()
focal_class.return: KafkaAuthenticationSpecificConfig
focal_class.signature: KafkaAuthenticationSpecificConfig getInstance()
focal_class.class_method_signature: KafkaAuthenticationSpecificConfig.isApplicable(final Connection connection)
focal_class.full_signature: @Override public boolean isApplicable(final Connection connection)
focal_class.identifier: isApplicable
focal_class.modifiers: @Override public
focal_class.parameters: (final Connection connection)
focal_class.return: boolean
focal_class.signature: boolean isApplicable(final Connection connection)
focal_class.class_method_signature: KafkaAuthenticationSpecificConfig.validateOrThrow(final Connection connection, final DittoHeaders dittoHeaders)
focal_class.full_signature: @Override public void validateOrThrow(final Connection connection, final DittoHeaders dittoHeaders)
focal_class.identifier: validateOrThrow
focal_class.modifiers: @Override public
focal_class.parameters: (final Connection connection, final DittoHeaders dittoHeaders)
focal_class.return: void
focal_class.signature: void validateOrThrow(final Connection connection, final DittoHeaders dittoHeaders)
focal_class.class_method_signature: KafkaAuthenticationSpecificConfig.isValid(final Connection connection)
focal_class.full_signature: @Override public boolean isValid(final Connection connection)
focal_class.identifier: isValid
focal_class.modifiers: @Override public
focal_class.parameters: (final Connection connection)
focal_class.return: boolean
focal_class.signature: boolean isValid(final Connection connection)
focal_class.class_method_signature: KafkaAuthenticationSpecificConfig.containsValidSaslMechanismConfiguration(final Connection connection)
focal_class.full_signature: private static boolean containsValidSaslMechanismConfiguration(final Connection connection)
focal_class.identifier: containsValidSaslMechanismConfiguration
focal_class.modifiers: private static
focal_class.parameters: (final Connection connection)
focal_class.return: boolean
focal_class.signature: boolean containsValidSaslMechanismConfiguration(final Connection connection)
focal_class.class_method_signature: KafkaAuthenticationSpecificConfig.apply(final HashMap<String, Object> producerProperties, final Connection connection)
focal_class.full_signature: @Override public void apply(final HashMap<String, Object> producerProperties, final Connection connection)
focal_class.identifier: apply
focal_class.modifiers: @Override public
focal_class.parameters: (final HashMap<String, Object> producerProperties, final Connection connection)
focal_class.return: void
focal_class.signature: void apply(final HashMap<String, Object> producerProperties, final Connection connection)
focal_class.class_method_signature: KafkaAuthenticationSpecificConfig.getJaasConfig(final String loginModule, final String username, final String password)
focal_class.full_signature: private static String getJaasConfig(final String loginModule, final String username, final String password)
focal_class.identifier: getJaasConfig
focal_class.modifiers: private static
focal_class.parameters: (final String loginModule, final String username, final String password)
focal_class.return: String
focal_class.signature: String getJaasConfig(final String loginModule, final String username, final String password)
focal_class.class_method_signature: KafkaAuthenticationSpecificConfig.getSaslMechanismOrDefault(final Connection connection)
focal_class.full_signature: private static String getSaslMechanismOrDefault(final Connection connection)
focal_class.identifier: getSaslMechanismOrDefault
focal_class.modifiers: private static
focal_class.parameters: (final Connection connection)
focal_class.return: String
focal_class.signature: String getSaslMechanismOrDefault(final Connection connection)
focal_class.class_method_signature: KafkaAuthenticationSpecificConfig.getLoginModuleForSaslMechanism(final String saslMechanism)
focal_class.full_signature: private static String getLoginModuleForSaslMechanism(final String saslMechanism)
focal_class.identifier: getLoginModuleForSaslMechanism
focal_class.modifiers: private static
focal_class.parameters: (final String saslMechanism)
focal_class.return: String
focal_class.signature: String getLoginModuleForSaslMechanism(final String saslMechanism)
focal_method.body: @Override
      public boolean isValid(final Connection connection) {
          return containsValidSaslMechanismConfiguration(connection);
      }
focal_method.class_method_signature: KafkaAuthenticationSpecificConfig.isValid(final Connection connection)
focal_method.full_signature: @Override public boolean isValid(final Connection connection)
focal_method.identifier: isValid
focal_method.invocations: containsValidSaslMechanismConfiguration
focal_method.modifiers: @Override public
focal_method.parameters: (final Connection connection)
focal_method.return: boolean
focal_method.signature: boolean isValid(final Connection connection)