This is an automated email from the ASF dual-hosted git repository. davsclaus pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/camel.git
The following commit(s) were added to refs/heads/main by this push: new baecbcd86a6 CAMEL-20522: Fix tests to ensure they stop camel baecbcd86a6 is described below commit baecbcd86a6dd8da7640dda232a4012af8bc9921 Author: Claus Ibsen <claus.ib...@gmail.com> AuthorDate: Thu Mar 14 11:27:01 2024 +0100 CAMEL-20522: Fix tests to ensure they stop camel --- .../micrometer/DistributionSummaryRouteTest.java | 2 +- .../messagehistory/ManagedMessageHistoryTest.java | 6 +++--- .../routepolicy/AbstractMicrometerRoutePolicyTest.java | 18 +++--------------- 3 files changed, 7 insertions(+), 19 deletions(-) diff --git a/components/camel-micrometer/src/test/java/org/apache/camel/component/micrometer/DistributionSummaryRouteTest.java b/components/camel-micrometer/src/test/java/org/apache/camel/component/micrometer/DistributionSummaryRouteTest.java index fea95615e66..a8ffd130e96 100644 --- a/components/camel-micrometer/src/test/java/org/apache/camel/component/micrometer/DistributionSummaryRouteTest.java +++ b/components/camel-micrometer/src/test/java/org/apache/camel/component/micrometer/DistributionSummaryRouteTest.java @@ -75,7 +75,7 @@ public class DistributionSummaryRouteTest extends CamelSpringTestSupport { } @AfterEach - public void tearDown() { + public void resetEndpoint() { endpoint.reset(); } diff --git a/components/camel-micrometer/src/test/java/org/apache/camel/component/micrometer/messagehistory/ManagedMessageHistoryTest.java b/components/camel-micrometer/src/test/java/org/apache/camel/component/micrometer/messagehistory/ManagedMessageHistoryTest.java index 030b6a6cd08..a1b7a5d7de8 100644 --- a/components/camel-micrometer/src/test/java/org/apache/camel/component/micrometer/messagehistory/ManagedMessageHistoryTest.java +++ b/components/camel-micrometer/src/test/java/org/apache/camel/component/micrometer/messagehistory/ManagedMessageHistoryTest.java @@ -33,6 +33,7 @@ import org.apache.camel.component.micrometer.CamelJmxConfig; import org.apache.camel.component.micrometer.MicrometerConstants; import org.apache.camel.component.mock.MockEndpoint; import org.apache.camel.test.junit5.CamelTestSupport; +import org.junit.jupiter.api.AfterEach; import org.junit.jupiter.api.Test; import org.slf4j.Logger; import org.slf4j.LoggerFactory; @@ -63,9 +64,8 @@ public class ManagedMessageHistoryTest extends CamelTestSupport { meterRegistry.add(new JmxMeterRegistry(CamelJmxConfig.DEFAULT, Clock.SYSTEM, HierarchicalNameMapper.DEFAULT)); } - @Override - public void tearDown() throws Exception { - super.tearDown(); + @AfterEach + protected void cleanupMeterRegistry() { if (meterRegistry != null) { meterRegistry.clear(); meterRegistry.close(); diff --git a/components/camel-micrometer/src/test/java/org/apache/camel/component/micrometer/routepolicy/AbstractMicrometerRoutePolicyTest.java b/components/camel-micrometer/src/test/java/org/apache/camel/component/micrometer/routepolicy/AbstractMicrometerRoutePolicyTest.java index a144ce2b24a..287a19c19c8 100644 --- a/components/camel-micrometer/src/test/java/org/apache/camel/component/micrometer/routepolicy/AbstractMicrometerRoutePolicyTest.java +++ b/components/camel-micrometer/src/test/java/org/apache/camel/component/micrometer/routepolicy/AbstractMicrometerRoutePolicyTest.java @@ -20,8 +20,8 @@ import io.micrometer.core.instrument.MeterRegistry; import io.micrometer.core.instrument.simple.SimpleMeterRegistry; import org.apache.camel.CamelContext; import org.apache.camel.component.micrometer.MicrometerConstants; -import org.apache.camel.support.LifecycleStrategySupport; import org.apache.camel.test.junit5.CamelTestSupport; +import org.junit.jupiter.api.AfterEach; import org.slf4j.Logger; import org.slf4j.LoggerFactory; @@ -36,9 +36,8 @@ public abstract class AbstractMicrometerRoutePolicyTest extends CamelTestSupport return factory; } - @Override - public void tearDown() throws Exception { - super.tearDown(); + @AfterEach + protected void cleanupMeterRegistry() { if (meterRegistry != null) { meterRegistry.clear(); meterRegistry.close(); @@ -60,17 +59,6 @@ public abstract class AbstractMicrometerRoutePolicyTest extends CamelTestSupport context.addRoutePolicyFactory(factory); context.getRegistry().bind(MicrometerConstants.METRICS_REGISTRY_NAME, meterRegistry); context.addService(factory); - // TODO: CAMEL-20522 - context.addLifecycleStrategy(new LifecycleStrategySupport() { - @Override - public void onContextStopped(CamelContext context) { - if (meterRegistry != null) { - meterRegistry.clear(); - meterRegistry.close(); - meterRegistry = null; - } - } - }); return context; }