From e989f4e03b16972bc45d376e604d14e6ad83f8f6 Mon Sep 17 00:00:00 2001 From: Chris Bono Date: Fri, 24 Feb 2023 09:03:06 -0600 Subject: [PATCH] Add pause in functions IT after context close - The PulsarFunctionAdministrationIntegrationTests needs a pause after context close to give the stop policy time to run before verifying function status --- .../PulsarFunctionAdministrationIntegrationTests.java | 3 +++ 1 file changed, 3 insertions(+) diff --git a/spring-pulsar-spring-boot-autoconfigure/src/integration-test/java/org/springframework/pulsar/autoconfigure/PulsarFunctionAdministrationIntegrationTests.java b/spring-pulsar-spring-boot-autoconfigure/src/integration-test/java/org/springframework/pulsar/autoconfigure/PulsarFunctionAdministrationIntegrationTests.java index 82ed07eb..6de3b9de 100644 --- a/spring-pulsar-spring-boot-autoconfigure/src/integration-test/java/org/springframework/pulsar/autoconfigure/PulsarFunctionAdministrationIntegrationTests.java +++ b/spring-pulsar-spring-boot-autoconfigure/src/integration-test/java/org/springframework/pulsar/autoconfigure/PulsarFunctionAdministrationIntegrationTests.java @@ -162,6 +162,9 @@ class PulsarFunctionAdministrationIntegrationTests { } } + // Give app context time to close and run the stop policies + Thread.sleep(10000); + // Stop policy runs after context close - verify source are in expected state try (PulsarAdmin admin = getAdmin()) { assertSourceExistsWithStatus("rabbit-test-source-none", true, admin);