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);