This is an automated email from the ASF dual-hosted git repository. davsclaus pushed a commit to branch camel-3.x in repository https://gitbox.apache.org/repos/asf/camel.git
commit 78d2d826269a3cb31c799ea44be432b9085a3ce1 Author: Claus Ibsen <[email protected]> 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);
