@Override
    public FilteredMessage apply(Message msg) {
        try (var ignored = executionTime.time()) {
            return doApply(msg);
        }
    }
@Test
    void applyWithNoFilterAndOneDestination(MessageFactory messageFactory) {
        final var filter = createFilter(Map.of(), Set.of("indexer"));
        final var message = messageFactory.createMessage("msg", "src", Tools.nowUTC());
        message.addStream(defaultStream);

        final var filteredMessage = filter.apply(message);

        assertThat(filteredMessage.message()).isEqualTo(ImmutableMessage.wrap(message));
        assertThat(filteredMessage.destinations().keySet()).containsExactlyInAnyOrder("indexer");
        assertThat(filteredMessage.destinations().get("indexer")).containsExactlyInAnyOrder(defaultStream);
    }