You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by da...@apache.org on 2021/02/28 13:01:25 UTC

[camel] 05/05: CAMEL-16271: camel-core - ReactiveExecutor add option to turn on|off statistics

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 <cl...@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);