increasing wait for events to popup

spring-boot-examples/consumer-app/src/test/java/io/dapr/springboot/examples/consumer/ConsumerAppTests.java

@@ -55,7 +55,7 @@ void testMessageConsumer() throws InterruptedException, IOException {
 
 
     await()
-            .atMost(Duration.ofSeconds(5))
+            .atMost(Duration.ofSeconds(10))
             .until(subscriberRestController.getAllEvents()::size, equalTo(1));
 
 

spring-boot-examples/producer-app/src/test/java/io/dapr/springboot/examples/producer/ProducerAppTests.java

@@ -53,10 +53,9 @@ void testOrdersEndpointAndMessaging() throws InterruptedException, IOException {
 						.post("/orders")
 						.then()
 						.statusCode(200);
-
-
+
 		await()
-						.atMost(Duration.ofSeconds(5))
+						.atMost(Duration.ofSeconds(10))
 						.until(controller.getAllEvents()::size, equalTo(1));
 
 		given()
@@ -111,9 +110,10 @@ void testCustomersWorkflows() throws InterruptedException, IOException {
 						.statusCode(200);
 
 
-		assertEquals(1, customerStore.getCustomers().size());
+		await()
+						.atMost(Duration.ofSeconds(10))
+						.until(customerStore.getCustomers()::size, equalTo(1));
 		Customer customer = customerStore.getCustomer("salaboy");
-
 		assertEquals(true, customer.isInCustomerDB());
 		String workflowId = customer.getWorkflowId();
 		given()
@@ -127,7 +127,7 @@ void testCustomersWorkflows() throws InterruptedException, IOException {
 		assertEquals(1, customerStore.getCustomers().size());
 
 		await()
-          .atMost(Duration.ofSeconds(5))
+          .atMost(Duration.ofSeconds(10))
           .until(customerStore.getCustomer("salaboy")::isFollowUp, equalTo(true));
 
 	}