Spring/spring-pulsar
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Increase wait time on pulsar function IT

Browse Source
This commit is contained in:
Chris Bono
2023-01-17 12:52:37 -06:00
committed by GitHub
parent 9556f2b157
commit ccaf4d3d4f
1 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
spring-pulsar-spring-boot-autoconfigure/src/test/java/org/springframework/pulsar/autoconfigure/PulsarFunctionAdministrationIntegrationTests.java
View File

@@ -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()) {