@Test
public void forSignal() {

    final ThingId thingId = ThingId.of("the:thing");
    final String correlationId = "theCorrelation";
    final DittoHeaders headersWithCorrelationId = DittoHeaders.newBuilder().correlationId(correlationId).build();
    final Signal<?> signal = RetrieveThing.of(thingId, headersWithCorrelationId);
    final Instant before = Instant.now();
    final ConnectionMonitor.InfoProvider info = InfoProviderFactory.forSignal(signal);
    final Instant after = Instant.now();
    assertThat(info)
            .hasThingId(thingId)
            .hasCorrelationId(correlationId)
            .hasTimestampBetween(before, after);
}