ExampleIntegrationTest.java

    @Test
    void whenATENANTUserCreatedMessageIsConsumed_UserUploadsRequiredDocuments_OperatorAcceptedThem_ShouldPublishDocumentUploadCompletedMessageDto() throws IOException {
        testUserCreatedMessage = testUserCreatedMessage.toBuilder().userType(UserType.TENANT).build();

        final List<UUID> userDocumentUploadIds = givenUploadTasksOnUserCreation();
        givenUserSuccessFullyUploadedRequiredDocuments(userDocumentUploadIds);
        givenOperatorAcceptedAllDocuments(userDocumentUploadIds);

        final List<DocumentUploadCompletedMessageDto> documentUploadCompletedMessageDto = sqsTestHelper.retrieveDocumentUploadCompletedMessageDto();
        assertThat(documentUploadCompletedMessageDto).hasSize(1);
        assertThat(documentUploadCompletedMessageDto.get(0).getDocumentTypes()).containsAll(testUserCreatedMessage.getUserType().getRequiredDocuments());
        assertThat(documentUploadCompletedMessageDto.get(0).getUserUuid()).isEqualTo(testUserCreatedMessage.getUserUuid());
    }