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 2024/08/30 13:21:08 UTC
(camel) 02/02: CAMEL-21144: camel-core - Backlog tracer/debugger optimize to make it faster
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 1df940e6b581b150bebbf0f483719fce9d24fead
Author: Claus Ibsen <cl...@gmail.com>
AuthorDate: Fri Aug 30 15:19:33 2024 +0200
CAMEL-21144: camel-core - Backlog tracer/debugger optimize to make it faster
---
.../org/apache/camel/impl/console/TraceDevConsole.java | 14 +++++++-------
.../main/java/org/apache/camel/main/ProfileConfigurer.java | 7 +++++--
2 files changed, 12 insertions(+), 9 deletions(-)
diff --git a/core/camel-console/src/main/java/org/apache/camel/impl/console/TraceDevConsole.java b/core/camel-console/src/main/java/org/apache/camel/impl/console/TraceDevConsole.java
index 7dd63eabea9..c5de210a50d 100644
--- a/core/camel-console/src/main/java/org/apache/camel/impl/console/TraceDevConsole.java
+++ b/core/camel-console/src/main/java/org/apache/camel/impl/console/TraceDevConsole.java
@@ -40,7 +40,7 @@ public class TraceDevConsole extends AbstractDevConsole {
/**
* Whether to enable or disable tracing
*/
- public static final String ACTION = "action";
+ public static final String ENABLED = "enabled";
private Queue<BacklogTracerEventMessage> queue;
@@ -66,14 +66,14 @@ public class TraceDevConsole extends AbstractDevConsole {
protected String doCallText(Map<String, Object> options) {
StringBuilder sb = new StringBuilder();
- String action = (String) options.get(ACTION);
+ String enabled = (String) options.get(ENABLED);
BacklogTracer tracer = getCamelContext().getCamelContextExtension().getContextPlugin(BacklogTracer.class);
if (tracer != null) {
- if ("start".equals(action) || "enable".equals(action)) {
+ if ("true".equals(enabled)) {
tracer.setEnabled(true);
sb.append("Enabled: ").append(tracer.isEnabled()).append("\n");
- } else if ("stop".equals(action) || "disable".equals(action)) {
+ } else if ("false".equals(enabled)) {
tracer.setEnabled(false);
sb.append("Enabled: ").append(tracer.isEnabled()).append("\n");
} else {
@@ -104,14 +104,14 @@ public class TraceDevConsole extends AbstractDevConsole {
protected JsonObject doCallJson(Map<String, Object> options) {
JsonObject root = new JsonObject();
- String action = (String) options.get(ACTION);
+ String enabled = (String) options.get(ENABLED);
BacklogTracer tracer = getCamelContext().getCamelContextExtension().getContextPlugin(BacklogTracer.class);
if (tracer != null) {
- if ("start".equals(action) || "enable".equals(action)) {
+ if ("true".equals(enabled)) {
tracer.setEnabled(true);
root.put("enabled", tracer.isEnabled());
- } else if ("stop".equals(action) || "disable".equals(action)) {
+ } else if ("false".equals(enabled)) {
tracer.setEnabled(false);
root.put("enabled", tracer.isEnabled());
} else {
diff --git a/core/camel-main/src/main/java/org/apache/camel/main/ProfileConfigurer.java b/core/camel-main/src/main/java/org/apache/camel/main/ProfileConfigurer.java
index 561bef92678..3973098923e 100644
--- a/core/camel-main/src/main/java/org/apache/camel/main/ProfileConfigurer.java
+++ b/core/camel-main/src/main/java/org/apache/camel/main/ProfileConfigurer.java
@@ -44,8 +44,11 @@ public class ProfileConfigurer {
}
if ("dev".equals(profile)) {
- // make tracing enabled and limit to not capture too much data
- config.tracerConfig().withEnabled(true);
+ boolean standby = config.tracerConfig().isStandby();
+ if (!standby) {
+ // make tracing enabled (if not configured to be standby) and limit to not capture too much data
+ config.tracerConfig().withEnabled(true);
+ }
}
configureCommon(camelContext, profile, config);