@Test
public void testTestConnection() {

    new TestKit(actorSystem) {{
        final Props props =
                AmqpClientActor.propsForTests(connection, getRef(), getRef(),
                        (ac, el) -> mockConnection);
        final ActorRef amqpClientActor = actorSystem.actorOf(props);
        amqpClientActor.tell(TestConnection.of(connection, DittoHeaders.empty()), getRef());
        expectMsgClass(Status.Success.class);
    }};
}