AmqpValidator extends AbstractProtocolValidator { @Override protected void validateTarget(final Target target, final DittoHeaders dittoHeaders, final Supplier<String> targetDescription) { target.getHeaderMapping().ifPresent(mapping -> validateHeaderMapping(mapping, dittoHeaders)); validateTemplate(target.getAddress(), dittoHeaders, Resolvers.getPlaceholders()); }  static AmqpValidator newInstance(); @Override ConnectionType type(); @Override void validate(final Connection connection, final DittoHeaders dittoHeaders, final ActorSystem actorSystem);  }
@Test public void testValidPlaceholdersInTargetAddress() { final Target target = newTargetBuilder() .address("some.address.{{ topic:action-subject }}.{{ thing:id }}.{{ header:correlation-id }}") .authorizationContext(AUTHORIZATION_CONTEXT) .topics(Topic.LIVE_COMMANDS) .build(); UNDER_TEST.validateTarget(target, DittoHeaders.empty(), () -> "testTarget"); }