@Test
public void testReceiveThingEventAndExpectForwardToJMSProducer() throws JMSException {

    final Target target = TestConstants.Targets.TWIN_TARGET;
    new TestKit(actorSystem) {{
        final Props props = AmqpClientActor.propsForTests(connection, getRef(), getRef(),
                (ac, el) -> mockConnection);
        final ActorRef amqpClientActor = actorSystem.actorOf(props);
        amqpClientActor.tell(OpenConnection.of(CONNECTION_ID, DittoHeaders.empty()), getRef());
        expectMsg(CONNECTED_SUCCESS);
        sendThingEventAndExpectPublish(amqpClientActor, target, () -> getProducerForAddress(target.getAddress()));
    }};
}