From ccaf4d3d4f2109c992fba37e4a5094544bce9eda Mon Sep 17 00:00:00 2001 From: Chris Bono Date: Tue, 17 Jan 2023 12:52:37 -0600 Subject: [PATCH] Increase wait time on pulsar function IT --- .../PulsarFunctionAdministrationIntegrationTests.java | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/spring-pulsar-spring-boot-autoconfigure/src/test/java/org/springframework/pulsar/autoconfigure/PulsarFunctionAdministrationIntegrationTests.java b/spring-pulsar-spring-boot-autoconfigure/src/test/java/org/springframework/pulsar/autoconfigure/PulsarFunctionAdministrationIntegrationTests.java index 3ec92b74..c0b4347e 100644 --- a/spring-pulsar-spring-boot-autoconfigure/src/test/java/org/springframework/pulsar/autoconfigure/PulsarFunctionAdministrationIntegrationTests.java +++ b/spring-pulsar-spring-boot-autoconfigure/src/test/java/org/springframework/pulsar/autoconfigure/PulsarFunctionAdministrationIntegrationTests.java @@ -111,8 +111,8 @@ class PulsarFunctionAdministrationIntegrationTests { "--spring.rabbitmq.host=" + RABBITMQ_CONTAINER.getHost(), "--spring.rabbitmq.port=" + RABBITMQ_CONTAINER.getAmqpPort())) { - // Give source 10s to get ready before sending messages to rabbit - Thread.sleep(10000); + // Give source time to get ready + Thread.sleep(20000); // Send messages to rabbit and wait for them to come through the rabbit source RabbitTemplate rabbitTemplate = context.getBean(RabbitTemplate.class); @@ -134,8 +134,8 @@ class PulsarFunctionAdministrationIntegrationTests { "--spring.rabbitmq.host=" + RABBITMQ_CONTAINER.getHost(), "--spring.rabbitmq.port=" + RABBITMQ_CONTAINER.getAmqpPort())) { - // Give the source a few seconds to get ready - Thread.sleep(10000); + // Give source time to get ready + Thread.sleep(20000); // Verify the sources are up and running try (PulsarAdmin admin = getAdmin()) {