This is an automated email from the ASF dual-hosted git repository. davsclaus pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/camel.git
commit ffbc3eddbb787e2292680e83c3c73b747403c0da Author: Claus Ibsen <claus.ib...@gmail.com> AuthorDate: Sun Feb 28 14:00:12 2021 +0100 CAMEL-16271: camel-core - ReactiveExecutor add option to turn on|off statistics --- .../camel/management/ManagedDefaultReactiveExecutorTest.java | 9 +++++++++ 1 file changed, 9 insertions(+) diff --git a/core/camel-management/src/test/java/org/apache/camel/management/ManagedDefaultReactiveExecutorTest.java b/core/camel-management/src/test/java/org/apache/camel/management/ManagedDefaultReactiveExecutorTest.java index 60d0942..3873b7e 100644 --- a/core/camel-management/src/test/java/org/apache/camel/management/ManagedDefaultReactiveExecutorTest.java +++ b/core/camel-management/src/test/java/org/apache/camel/management/ManagedDefaultReactiveExecutorTest.java @@ -19,7 +19,9 @@ package org.apache.camel.management; import javax.management.MBeanServer; import javax.management.ObjectName; +import org.apache.camel.CamelContext; import org.apache.camel.Exchange; +import org.apache.camel.ExtendedCamelContext; import org.apache.camel.Processor; import org.apache.camel.builder.RouteBuilder; import org.junit.jupiter.api.Test; @@ -29,6 +31,13 @@ import static org.junit.jupiter.api.Assertions.assertTrue; public class ManagedDefaultReactiveExecutorTest extends ManagementTestSupport { + @Override + protected CamelContext createCamelContext() throws Exception { + CamelContext context = super.createCamelContext(); + context.adapt(ExtendedCamelContext.class).getReactiveExecutor().setStatisticsEnabled(true); + return context; + } + @Test public void testReactiveExecutor() throws Exception { getMockEndpoint("mock:result").expectedMessageCount(1);