@Test
public void receivedAllRequestedAcknowledgements() {

    final AcknowledgementAggregator underTest =
            AcknowledgementAggregator.getInstance(ENTITY_ID, correlationId, TIMEOUT, HEADER_TRANSLATOR);
    final List<Acknowledgement> acknowledgements = createAcknowledgements(3, HttpStatusCode.NO_CONTENT);
    acknowledgements.addAll(createAcknowledgements(2, HttpStatusCode.BAD_REQUEST));
    acknowledgements.forEach(
            ack -> underTest.addAcknowledgementRequest(AcknowledgementRequest.of(ack.getLabel())));
    acknowledgements.forEach(underTest::addReceivedAcknowledgment);
    assertThat(underTest.receivedAllRequestedAcknowledgements()).isTrue();
}