test_class.declarator: UNDER_TEST = AmqpValidator.newInstance()
test_class.modifier: private static final
test_class.original_string: private static final AmqpValidator UNDER_TEST = AmqpValidator.newInstance();
test_class.type: AmqpValidator
test_class.var_name: UNDER_TEST
test_class.file: services/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/amqp/AmqpValidatorTest.java
test_class.identifier: AmqpValidatorTest
test_case.body: @Test
      public void testValidMatchers() {
          final Source source = newSourceBuilder()
                  .enforcement(ConnectivityModelFactory.newEnforcement(
                          "{{ header:device_id }}", "{{ policy:id }}",
                          "{{ thing:id }}", "{{ entity:id }}"))
                  .build();
  
          UNDER_TEST.validateSource(source, DittoHeaders.empty(), () -> "testSource");
      }
test_case.class_method_signature: AmqpValidatorTest.testValidMatchers()
test_case.full_signature: @Test public void testValidMatchers()
test_case.identifier: testValidMatchers
test_case.invocations: build enforcement newSourceBuilder newEnforcement validateSource empty
test_case.modifiers: @Test public
test_case.parameters: ()
test_case.return: void
test_case.signature: void testValidMatchers()
focal_class.declarator: ACCEPTED_SCHEMES =
              Collections.unmodifiableList(Arrays.asList("amqp", "amqps"))
focal_class.modifier: private static final
focal_class.original_string: private static final Collection<String> ACCEPTED_SCHEMES =
              Collections.unmodifiableList(Arrays.asList("amqp", "amqps"));
focal_class.type: Collection<String>
focal_class.var_name: ACCEPTED_SCHEMES
focal_class.declarator: SECURE_SCHEMES = Collections.singletonList("amqps")
focal_class.modifier: private static final
focal_class.original_string: private static final Collection<String> SECURE_SCHEMES = Collections.singletonList("amqps");
focal_class.type: Collection<String>
focal_class.var_name: SECURE_SCHEMES
focal_class.file: services/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/amqp/AmqpValidator.java
focal_class.identifier: AmqpValidator
focal_class.class_method_signature: AmqpValidator.newInstance()
focal_class.full_signature: public static AmqpValidator newInstance()
focal_class.identifier: newInstance
focal_class.modifiers: public static
focal_class.parameters: ()
focal_class.return: AmqpValidator
focal_class.signature: AmqpValidator newInstance()
focal_class.class_method_signature: AmqpValidator.validateSource(final Source source, final DittoHeaders dittoHeaders,
              final Supplier<String> sourceDescription)
focal_class.full_signature: @Override protected void validateSource(final Source source, final DittoHeaders dittoHeaders,
              final Supplier<String> sourceDescription)
focal_class.identifier: validateSource
focal_class.modifiers: @Override protected
focal_class.parameters: (final Source source, final DittoHeaders dittoHeaders,
              final Supplier<String> sourceDescription)
focal_class.return: void
focal_class.signature: void validateSource(final Source source, final DittoHeaders dittoHeaders,
              final Supplier<String> sourceDescription)
focal_class.class_method_signature: AmqpValidator.validateTarget(final Target target, final DittoHeaders dittoHeaders,
              final Supplier<String> targetDescription)
focal_class.full_signature: @Override protected void validateTarget(final Target target, final DittoHeaders dittoHeaders,
              final Supplier<String> targetDescription)
focal_class.identifier: validateTarget
focal_class.modifiers: @Override protected
focal_class.parameters: (final Target target, final DittoHeaders dittoHeaders,
              final Supplier<String> targetDescription)
focal_class.return: void
focal_class.signature: void validateTarget(final Target target, final DittoHeaders dittoHeaders,
              final Supplier<String> targetDescription)
focal_class.class_method_signature: AmqpValidator.type()
focal_class.full_signature: @Override public ConnectionType type()
focal_class.identifier: type
focal_class.modifiers: @Override public
focal_class.parameters: ()
focal_class.return: ConnectionType
focal_class.signature: ConnectionType type()
focal_class.class_method_signature: AmqpValidator.validate(final Connection connection, final DittoHeaders dittoHeaders, final ActorSystem actorSystem)
focal_class.full_signature: @Override public void validate(final Connection connection, final DittoHeaders dittoHeaders, final ActorSystem actorSystem)
focal_class.identifier: validate
focal_class.modifiers: @Override public
focal_class.parameters: (final Connection connection, final DittoHeaders dittoHeaders, final ActorSystem actorSystem)
focal_class.return: void
focal_class.signature: void validate(final Connection connection, final DittoHeaders dittoHeaders, final ActorSystem actorSystem)
focal_class.superclass: extends AbstractProtocolValidator
focal_method.body: @Override
      protected void validateSource(final Source source, final DittoHeaders dittoHeaders,
              final Supplier<String> sourceDescription) {
  
          source.getEnforcement().ifPresent(enforcement -> {
              validateTemplate(enforcement.getInput(), dittoHeaders, PlaceholderFactory.newHeadersPlaceholder());
              enforcement.getFilters().forEach(filterTemplate ->
                      validateTemplate(filterTemplate, dittoHeaders, PlaceholderFactory.newThingPlaceholder(),
                              PlaceholderFactory.newPolicyPlaceholder(),
                              PlaceholderFactory.newEntityPlaceholder()));
          });
          source.getHeaderMapping().ifPresent(mapping -> validateHeaderMapping(mapping, dittoHeaders));
      }
focal_method.class_method_signature: AmqpValidator.validateSource(final Source source, final DittoHeaders dittoHeaders,
              final Supplier<String> sourceDescription)
focal_method.full_signature: @Override protected void validateSource(final Source source, final DittoHeaders dittoHeaders,
              final Supplier<String> sourceDescription)
focal_method.identifier: validateSource
focal_method.invocations: ifPresent getEnforcement validateTemplate getInput newHeadersPlaceholder forEach getFilters validateTemplate newThingPlaceholder newPolicyPlaceholder newEntityPlaceholder ifPresent getHeaderMapping validateHeaderMapping
focal_method.modifiers: @Override protected
focal_method.parameters: (final Source source, final DittoHeaders dittoHeaders,
              final Supplier<String> sourceDescription)
focal_method.return: void
focal_method.signature: void validateSource(final Source source, final DittoHeaders dittoHeaders,
              final Supplier<String> sourceDescription)