@Test
public void forHeaders() {

    final String correlationId = "theCorrelation";
    final Map<String, String> headersWithCorrelationId = DittoHeaders.newBuilder().correlationId(correlationId).build();
    final Instant before = Instant.now();
    final ConnectionMonitor.InfoProvider info = InfoProviderFactory.forHeaders(headersWithCorrelationId);
    final Instant after = Instant.now();
    assertThat(info)
            .hasNoThingId()
            .hasCorrelationId(correlationId)
            .hasTimestampBetween(before, after);
}