Skip to content

Commit

Permalink
Merge branch 'develop' into fix/conquery-execption-mapper
Browse files Browse the repository at this point in the history
  • Loading branch information
thoniTUB authored Jan 14, 2025
2 parents 8e057e9 + b61bfee commit 968aac7
Show file tree
Hide file tree
Showing 2 changed files with 3 additions and 2 deletions.
2 changes: 1 addition & 1 deletion backend/pom.xml
Original file line number Diff line number Diff line change
Expand Up @@ -219,7 +219,7 @@
<dependency>
<groupId>org.apache.mina</groupId>
<artifactId>mina-core</artifactId>
<version>2.1.5</version>
<version>2.2.4</version>
</dependency>
<dependency>
<groupId>org.apache.shiro</groupId>
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -184,8 +184,9 @@ public void exceptionCaught(IoSession session, Throwable cause) {
// Wait until all clients completed writing
CompletableFuture.allOf(clientThreads.toArray(new CompletableFuture[0])).join();

log.info("Waiting to receive all send messages");
// Wait until all messages are received
await().atMost(10,TimeUnit.SECONDS).until(() -> SERVER_RECEIVED_MESSAGES.size() == messagesWritten.size());
await().atMost(10,TimeUnit.SECONDS).alias("Send and received same amount of messages").until(() -> SERVER_RECEIVED_MESSAGES.size() == messagesWritten.size());

// Check that the messages are correct
assertThat(SERVER_RECEIVED_MESSAGES).containsExactlyInAnyOrderElementsOf(messagesWritten);
Expand Down

0 comments on commit 968aac7

Please sign in to comment.