reactive-commons
diff --git a/‎async/async-commons/src/test/java/org/reactivecommons/async/impl/RabbitDirectAsyncGatewayTest.java‎
Lines changed: 1 addition & 1 deletion b/‎async/async-commons/src/test/java/org/reactivecommons/async/impl/RabbitDirectAsyncGatewayTest.java‎
Lines changed: 1 addition & 1 deletion
diff --git a/‎samples/async/simpleConsumer/src/main/resources/application.properties‎ b/‎samples/async/simpleConsumer/src/main/resources/application.properties‎
@@ -64,7 +64,7 @@ public void shouldSendInOptimalTime() throws InterruptedException {
         System.out.println("Message count: " + messageCount);
         System.out.println("Total Execution Time: " + total + "ms");
         System.out.println("Microseconds per message: " + microsPerMessage + "us");
-        Assertions.assertThat(microsPerMessage).isLessThan(50);
+        Assertions.assertThat(microsPerMessage).isLessThan(150);
     }
 
     private ReactiveMessageSender getReactiveMessageSender() {
Original file line number	Diff line number	Diff line change
`@@ -64,7 +64,7 @@ public void shouldSendInOptimalTime() throws InterruptedException {`
`64`	`64`	`System.out.println("Message count: " + messageCount);`
`65`	`65`	`System.out.println("Total Execution Time: " + total + "ms");`
`66`	`66`	`System.out.println("Microseconds per message: " + microsPerMessage + "us");`
`67`		`- Assertions.assertThat(microsPerMessage).isLessThan(50);`
	`67`	`+ Assertions.assertThat(microsPerMessage).isLessThan(150);`
`68`	`68`	`}`
`69`	`69`
`70`	`70`	`private ReactiveMessageSender getReactiveMessageSender() {`