@Test
public void retrieveLogsIsAggregated() {

    final Instant now = Instant.now();
    final RetrieveConnectionLogsResponse innerResponse = RetrieveConnectionLogsResponse.of(connectionId,
            TestConstants.Monitoring.LOG_ENTRIES,
            now.minusSeconds(312),
            now.plusSeconds(123),
            DittoHeaders.empty());
    new TestKit(actorSystem) {{
        final TestProbe probe = TestProbe.apply(actorSystem);
        final ActorRef underTest =
                TestConstants.createConnectionSupervisorActor(connectionId, actorSystem, pubSubMediator,
                        proxyActor,
                        (connection, concierge, connectionActor) -> MockClientActor.props(probe.ref()));
        watch(underTest);
        // create connection
        underTest.tell(createConnection, getRef());
        probe.expectMsg(openConnection);
        expectMsg(createConnectionResponse);
        // retrieve logs
        final RetrieveConnectionLogs retrieveConnectionLogs =
                RetrieveConnectionLogs.of(connectionId, DittoHeaders.empty());
        underTest.tell(retrieveConnectionLogs, getRef());
        probe.expectMsg(retrieveConnectionLogs);
        // send answer to aggregator actor
        final ActorRef aggregatorActor = probe.sender();
        probe.send(aggregatorActor, innerResponse);
        expectMsg(innerResponse);
    }};
}