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 2023/02/09 07:42:28 UTC
[camel] 03/04: CAMEL-19026: camel-main - Add camel.main.backlogTracingStandby option.
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
commit 3c89ceef8e5038269beac7ad0556a8e0b90c6e85
Author: Claus Ibsen <cl...@gmail.com>
AuthorDate: Thu Feb 9 08:36:29 2023 +0100
CAMEL-19026: camel-main - Add camel.main.backlogTracingStandby option.
---
.../camel/management/BacklogTracerFilterTest.java | 2 +-
.../management/BacklogTracerIdOnAllNodesTest.java | 2 +-
.../management/BacklogTracerPatternRouteTest.java | 2 +-
.../camel/management/BacklogTracerPatternTest.java | 2 +-
.../management/BacklogTracerStreamCachingTest.java | 2 +-
.../apache/camel/management/BacklogTracerTest.java | 35 +++++-----------------
6 files changed, 12 insertions(+), 33 deletions(-)
diff --git a/core/camel-management/src/test/java/org/apache/camel/management/BacklogTracerFilterTest.java b/core/camel-management/src/test/java/org/apache/camel/management/BacklogTracerFilterTest.java
index 3ac467aa074..e45e6e7e782 100644
--- a/core/camel-management/src/test/java/org/apache/camel/management/BacklogTracerFilterTest.java
+++ b/core/camel-management/src/test/java/org/apache/camel/management/BacklogTracerFilterTest.java
@@ -109,7 +109,7 @@ public class BacklogTracerFilterTest extends ManagementTestSupport {
@Override
public void configure() throws Exception {
context.setUseBreadcrumb(false);
- context.setBacklogTracing(true);
+ context.setBacklogTracingStandby(true);
from("direct:start")
.to("mock:foo").id("foo")
diff --git a/core/camel-management/src/test/java/org/apache/camel/management/BacklogTracerIdOnAllNodesTest.java b/core/camel-management/src/test/java/org/apache/camel/management/BacklogTracerIdOnAllNodesTest.java
index eb86ab60810..28ca05cf89a 100644
--- a/core/camel-management/src/test/java/org/apache/camel/management/BacklogTracerIdOnAllNodesTest.java
+++ b/core/camel-management/src/test/java/org/apache/camel/management/BacklogTracerIdOnAllNodesTest.java
@@ -137,7 +137,7 @@ public class BacklogTracerIdOnAllNodesTest extends ManagementTestSupport {
@Override
public void configure() throws Exception {
context.setUseBreadcrumb(false);
- context.setBacklogTracing(true);
+ context.setBacklogTracingStandby(true);
from("direct:start")
.choice()
diff --git a/core/camel-management/src/test/java/org/apache/camel/management/BacklogTracerPatternRouteTest.java b/core/camel-management/src/test/java/org/apache/camel/management/BacklogTracerPatternRouteTest.java
index b559a0d573b..c77caa44f9e 100644
--- a/core/camel-management/src/test/java/org/apache/camel/management/BacklogTracerPatternRouteTest.java
+++ b/core/camel-management/src/test/java/org/apache/camel/management/BacklogTracerPatternRouteTest.java
@@ -88,7 +88,7 @@ public class BacklogTracerPatternRouteTest extends ManagementTestSupport {
@Override
public void configure() throws Exception {
context.setUseBreadcrumb(false);
- context.setBacklogTracing(true);
+ context.setBacklogTracingStandby(true);
from("direct:start").routeId("coolRoute")
.to("direct:beer")
diff --git a/core/camel-management/src/test/java/org/apache/camel/management/BacklogTracerPatternTest.java b/core/camel-management/src/test/java/org/apache/camel/management/BacklogTracerPatternTest.java
index 9f194f8e74d..920c3065f6e 100644
--- a/core/camel-management/src/test/java/org/apache/camel/management/BacklogTracerPatternTest.java
+++ b/core/camel-management/src/test/java/org/apache/camel/management/BacklogTracerPatternTest.java
@@ -100,7 +100,7 @@ public class BacklogTracerPatternTest extends ManagementTestSupport {
@Override
public void configure() throws Exception {
context.setUseBreadcrumb(false);
- context.setBacklogTracing(true);
+ context.setBacklogTracingStandby(true);
from("direct:start")
.to("mock:foo").id("foo")
diff --git a/core/camel-management/src/test/java/org/apache/camel/management/BacklogTracerStreamCachingTest.java b/core/camel-management/src/test/java/org/apache/camel/management/BacklogTracerStreamCachingTest.java
index fb7cd9406d5..41502002a0f 100644
--- a/core/camel-management/src/test/java/org/apache/camel/management/BacklogTracerStreamCachingTest.java
+++ b/core/camel-management/src/test/java/org/apache/camel/management/BacklogTracerStreamCachingTest.java
@@ -89,7 +89,7 @@ public class BacklogTracerStreamCachingTest extends ManagementTestSupport {
@Override
public void configure() throws Exception {
context.setUseBreadcrumb(false);
- context.setBacklogTracing(true);
+ context.setBacklogTracingStandby(true);
from("direct:start").streamCaching()
.process(exchange -> {
diff --git a/core/camel-management/src/test/java/org/apache/camel/management/BacklogTracerTest.java b/core/camel-management/src/test/java/org/apache/camel/management/BacklogTracerTest.java
index a0bbf1e31ea..d2ef42331a6 100644
--- a/core/camel-management/src/test/java/org/apache/camel/management/BacklogTracerTest.java
+++ b/core/camel-management/src/test/java/org/apache/camel/management/BacklogTracerTest.java
@@ -49,7 +49,7 @@ public class BacklogTracerTest extends ManagementTestSupport {
assertTrue(mbeanServer.isRegistered(on));
Boolean enabled = (Boolean) mbeanServer.getAttribute(on, "Enabled");
- assertEquals(Boolean.FALSE, enabled, "Should not be enabled");
+ assertEquals(Boolean.TRUE, enabled, "Should be enabled");
Integer size = (Integer) mbeanServer.getAttribute(on, "BacklogSize");
assertEquals(1000, size.intValue(), "Should be 1000");
@@ -57,9 +57,6 @@ public class BacklogTracerTest extends ManagementTestSupport {
Boolean removeOnDump = (Boolean) mbeanServer.getAttribute(on, "RemoveOnDump");
assertEquals(Boolean.TRUE, removeOnDump);
- // enable it
- mbeanServer.setAttribute(on, new Attribute("Enabled", Boolean.TRUE));
-
getMockEndpoint("mock:foo").expectedMessageCount(2);
getMockEndpoint("mock:bar").expectedMessageCount(2);
@@ -100,14 +97,11 @@ public class BacklogTracerTest extends ManagementTestSupport {
mbeanServer.isRegistered(on);
Boolean enabled = (Boolean) mbeanServer.getAttribute(on, "Enabled");
- assertEquals(Boolean.FALSE, enabled, "Should not be enabled");
+ assertEquals(Boolean.TRUE, enabled, "Should be enabled");
Integer size = (Integer) mbeanServer.getAttribute(on, "BacklogSize");
assertEquals(1000, size.intValue(), "Should be 1000");
- // enable it
- mbeanServer.setAttribute(on, new Attribute("Enabled", Boolean.TRUE));
-
getMockEndpoint("mock:foo").expectedMessageCount(2);
getMockEndpoint("mock:bar").expectedMessageCount(2);
@@ -140,10 +134,7 @@ public class BacklogTracerTest extends ManagementTestSupport {
mbeanServer.isRegistered(on);
Boolean enabled = (Boolean) mbeanServer.getAttribute(on, "Enabled");
- assertEquals(Boolean.FALSE, enabled, "Should not be enabled");
-
- // enable it
- mbeanServer.setAttribute(on, new Attribute("Enabled", Boolean.TRUE));
+ assertEquals(Boolean.TRUE, enabled, "Should be enabled");
getMockEndpoint("mock:foo").expectedMessageCount(2);
getMockEndpoint("mock:bar").expectedMessageCount(2);
@@ -220,10 +211,7 @@ public class BacklogTracerTest extends ManagementTestSupport {
mbeanServer.isRegistered(on);
Boolean enabled = (Boolean) mbeanServer.getAttribute(on, "Enabled");
- assertEquals(Boolean.FALSE, enabled, "Should not be enabled");
-
- // enable it
- mbeanServer.setAttribute(on, new Attribute("Enabled", Boolean.TRUE));
+ assertEquals(Boolean.TRUE, enabled, "Should not be enabled");
getMockEndpoint("mock:foo").expectedMessageCount(2);
getMockEndpoint("mock:bar").expectedMessageCount(2);
@@ -261,10 +249,7 @@ public class BacklogTracerTest extends ManagementTestSupport {
mbeanServer.setAttribute(on, new Attribute("RemoveOnDump", Boolean.FALSE));
Boolean enabled = (Boolean) mbeanServer.getAttribute(on, "Enabled");
- assertEquals(Boolean.FALSE, enabled, "Should not be enabled");
-
- // enable it
- mbeanServer.setAttribute(on, new Attribute("Enabled", Boolean.TRUE));
+ assertEquals(Boolean.TRUE, enabled, "Should not be enabled");
getMockEndpoint("mock:foo").expectedMessageCount(2);
getMockEndpoint("mock:bar").expectedMessageCount(2);
@@ -316,10 +301,7 @@ public class BacklogTracerTest extends ManagementTestSupport {
mbeanServer.setAttribute(on, new Attribute("RemoveOnDump", Boolean.FALSE));
Boolean enabled = (Boolean) mbeanServer.getAttribute(on, "Enabled");
- assertEquals(Boolean.FALSE, enabled, "Should not be enabled");
-
- // enable it
- mbeanServer.setAttribute(on, new Attribute("Enabled", Boolean.TRUE));
+ assertEquals(Boolean.TRUE, enabled, "Should be enabled");
getMockEndpoint("mock:foo").expectedMessageCount(2);
getMockEndpoint("mock:bar").expectedMessageCount(2);
@@ -385,10 +367,7 @@ public class BacklogTracerTest extends ManagementTestSupport {
mbeanServer.setAttribute(on, new Attribute("TracePattern", "foo"));
Boolean enabled = (Boolean) mbeanServer.getAttribute(on, "Enabled");
- assertEquals(Boolean.FALSE, enabled, "Should not be enabled");
-
- // enable it
- mbeanServer.setAttribute(on, new Attribute("Enabled", Boolean.TRUE));
+ assertEquals(Boolean.TRUE, enabled, "Should not be enabled");
getMockEndpoint("mock:foo").expectedMessageCount(10);
getMockEndpoint("mock:bar").expectedMessageCount(10);