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 2013/03/19 17:46:56 UTC
svn commit: r1458399 - in /camel/trunk/platforms/karaf/commands/src/main:
java/org/apache/camel/karaf/commands/ resources/OSGI-INF/blueprint/
Author: davsclaus
Date: Tue Mar 19 16:46:56 2013
New Revision: 1458399
URL: http://svn.apache.org/r1458399
Log:
CAMEL-6149: Backlog tracer karaf command. Work in progress.
Added:
camel/trunk/platforms/karaf/commands/src/main/java/org/apache/camel/karaf/commands/BacklogTracerDump.java
- copied, changed from r1458241, camel/trunk/platforms/karaf/commands/src/main/java/org/apache/camel/karaf/commands/BacklogTracerCommand.java
camel/trunk/platforms/karaf/commands/src/main/java/org/apache/camel/karaf/commands/BacklogTracerInfo.java
- copied, changed from r1458241, camel/trunk/platforms/karaf/commands/src/main/java/org/apache/camel/karaf/commands/BacklogTracerCommand.java
camel/trunk/platforms/karaf/commands/src/main/java/org/apache/camel/karaf/commands/BacklogTracerStart.java
- copied, changed from r1458241, camel/trunk/platforms/karaf/commands/src/main/java/org/apache/camel/karaf/commands/BacklogTracerCommand.java
camel/trunk/platforms/karaf/commands/src/main/java/org/apache/camel/karaf/commands/BacklogTracerStop.java
Removed:
camel/trunk/platforms/karaf/commands/src/main/java/org/apache/camel/karaf/commands/BacklogTracerCommand.java
Modified:
camel/trunk/platforms/karaf/commands/src/main/resources/OSGI-INF/blueprint/camel-commands.xml
Copied: camel/trunk/platforms/karaf/commands/src/main/java/org/apache/camel/karaf/commands/BacklogTracerDump.java (from r1458241, camel/trunk/platforms/karaf/commands/src/main/java/org/apache/camel/karaf/commands/BacklogTracerCommand.java)
URL: http://svn.apache.org/viewvc/camel/trunk/platforms/karaf/commands/src/main/java/org/apache/camel/karaf/commands/BacklogTracerDump.java?p2=camel/trunk/platforms/karaf/commands/src/main/java/org/apache/camel/karaf/commands/BacklogTracerDump.java&p1=camel/trunk/platforms/karaf/commands/src/main/java/org/apache/camel/karaf/commands/BacklogTracerCommand.java&r1=1458241&r2=1458399&rev=1458399&view=diff
==============================================================================
--- camel/trunk/platforms/karaf/commands/src/main/java/org/apache/camel/karaf/commands/BacklogTracerCommand.java (original)
+++ camel/trunk/platforms/karaf/commands/src/main/java/org/apache/camel/karaf/commands/BacklogTracerDump.java Tue Mar 19 16:46:56 2013
@@ -35,23 +35,18 @@ import org.apache.karaf.shell.console.Os
/**
* Command to use the <a href="camel.apache.org/backlogtracer">Backlog Tracer</a>.
*/
-@Command(scope = "camel", name = "backlog-tracer", description = "Access the Backlog tracer")
-public class BacklogTracerCommand extends OsgiCommandSupport {
-
- @Option(name ="-a", aliases = {"--action"}, description = "The action to perform.", required = true, multiValued = false)
- String action;
+@Command(scope = "camel", name = "backlog-tracer-dump", description = "Dumps traced messages from the Backlog tracer")
+public class BacklogTracerDump extends OsgiCommandSupport {
@Argument(index = 0, name = "context", description = "The name of the Camel context.", required = true, multiValued = false)
String context;
- @Argument(index = 1, name = "pattern", description = "To trace/dump trace messages only for nodes matching the given pattern (default is all)", required = false, multiValued = false)
+ @Argument(index = 1, name = "pattern", description = "To dump trace messages only for nodes or routes matching the given pattern (default is all)", required = false, multiValued = false)
String pattern;
- @Argument(index = 2, name = "format", description = "Format to use with the dump action (default is xml)", required = false, multiValued = false)
+ @Option(name = "--format", aliases = "-f", description = "Format to use with the dump action (table or xml)", required = false, multiValued = false, valueToShowInHelp = "xml")
String format;
- // TODO: need to work on a better command syntax to make it easier to use
-
private CamelController camelController;
public void setCamelController(CamelController camelController) {
@@ -71,52 +66,38 @@ public class BacklogTracerCommand extend
backlogTracer = (BacklogTracer) camel.getDefaultBacklogTracer();
}
- if ("enable".equals(action)) {
- backlogTracer.setEnabled(true);
+ if (format == null || "xml".equals(format)) {
+ System.out.println("--------------------------------------------------------");
if (pattern != null) {
- backlogTracer.setTracePattern(pattern);
- System.out.println("BacklogTracer enabled on " + camel.getName() + " using pattern: " + pattern);
+ System.out.println("BacklogTracer messages:\n" + backlogTracer.dumpTracedMessages(pattern));
} else {
- System.out.println("BacklogTracer enabled on " + camel.getName());
+ System.out.println("BacklogTracer messages:\n" + backlogTracer.dumpAllTracedMessagesAsXml());
}
return null;
- } else if ("disable".equals(action)) {
- backlogTracer.setEnabled(false);
- backlogTracer.setTracePattern(null);
- System.out.println("BacklogTracer disabled on " + camel.getName());
- return null;
- } else if ("summary".equals(action)) {
- System.out.println("BacklogTracer context:" + camel.getName());
- System.out.println("BacklogTracer enabled:" + backlogTracer.isEnabled());
- System.out.println("BacklogTracer pattern:" + (backlogTracer.getTracePattern() != null ? backlogTracer.getTracePattern() : ""));
- System.out.println("BacklogTracer backlogSize:" + backlogTracer.getBacklogSize());
- System.out.println("BacklogTracer tracerCount:" + backlogTracer.getTraceCounter());
- return null;
- } else if ("dump".equals(action)) {
- if (format == null || "xml".equals(format)) {
+ } else if ("table".equals(format)) {
+ JAXBContext context = JAXBContext.newInstance(MessageDump.class);
+ Unmarshaller unmarshaller = context.createUnmarshaller();
+
+ // assume its a table
+ SimpleDateFormat sdf = new SimpleDateFormat(BacklogTracerEventMessage.TIMESTAMP_FORMAT);
+ List<BacklogTracerEventMessage> events;
+ if (pattern != null) {
+ events = backlogTracer.dumpTracedMessages(pattern);
+ } else {
+ events = backlogTracer.dumpAllTracedMessages();
+ }
+ for (BacklogTracerEventMessage event : events) {
System.out.println("--------------------------------------------------------");
- System.out.println("BacklogTracer messages:\n" + backlogTracer.dumpAllTracedMessagesAsXml());
- return null;
- } else if ("table".equals(format)) {
- JAXBContext context = JAXBContext.newInstance(MessageDump.class);
- Unmarshaller unmarshaller = context.createUnmarshaller();
-
- // assume its a table
- SimpleDateFormat sdf = new SimpleDateFormat(BacklogTracerEventMessage.TIMESTAMP_FORMAT);
- List<BacklogTracerEventMessage> events = backlogTracer.dumpAllTracedMessages();
- for (BacklogTracerEventMessage event : events) {
- System.out.println("--------------------------------------------------------");
- System.out.println("#" + event.getUid() + "\tExchangeId: " + event.getExchangeId());
- System.out.println("Timestamp: " + sdf.format(event.getTimestamp()));
- System.out.println("Route: " + event.getRouteId() + " --> " + event.getToNode());
-
- MessageDump msg = (MessageDump) unmarshaller.unmarshal(new StringReader(event.getMessageAsXml()));
- String breadcrumb = getBreadcrumbId(msg.getHeaders());
- if (breadcrumb != null) {
- System.out.println("Breadcrumb: " + breadcrumb);
- }
- System.out.println("Body: " + msg.getBody().getValue());
+ System.out.println("#" + event.getUid() + "\tExchangeId: " + event.getExchangeId());
+ System.out.println("Timestamp: " + sdf.format(event.getTimestamp()));
+ System.out.println("Route: " + event.getRouteId() + " --> " + event.getToNode());
+
+ MessageDump msg = (MessageDump) unmarshaller.unmarshal(new StringReader(event.getMessageAsXml()));
+ String breadcrumb = getBreadcrumbId(msg.getHeaders());
+ if (breadcrumb != null) {
+ System.out.println("Breadcrumb: " + breadcrumb);
}
+ System.out.println("Body: " + msg.getBody().getValue());
}
}
Copied: camel/trunk/platforms/karaf/commands/src/main/java/org/apache/camel/karaf/commands/BacklogTracerInfo.java (from r1458241, camel/trunk/platforms/karaf/commands/src/main/java/org/apache/camel/karaf/commands/BacklogTracerCommand.java)
URL: http://svn.apache.org/viewvc/camel/trunk/platforms/karaf/commands/src/main/java/org/apache/camel/karaf/commands/BacklogTracerInfo.java?p2=camel/trunk/platforms/karaf/commands/src/main/java/org/apache/camel/karaf/commands/BacklogTracerInfo.java&p1=camel/trunk/platforms/karaf/commands/src/main/java/org/apache/camel/karaf/commands/BacklogTracerCommand.java&r1=1458241&r2=1458399&rev=1458399&view=diff
==============================================================================
--- camel/trunk/platforms/karaf/commands/src/main/java/org/apache/camel/karaf/commands/BacklogTracerCommand.java (original)
+++ camel/trunk/platforms/karaf/commands/src/main/java/org/apache/camel/karaf/commands/BacklogTracerInfo.java Tue Mar 19 16:46:56 2013
@@ -16,42 +16,21 @@
*/
package org.apache.camel.karaf.commands;
-import java.io.StringReader;
-import java.text.SimpleDateFormat;
-import java.util.List;
-import javax.xml.bind.JAXBContext;
-import javax.xml.bind.Unmarshaller;
-
import org.apache.camel.CamelContext;
-import org.apache.camel.Exchange;
-import org.apache.camel.api.management.mbean.BacklogTracerEventMessage;
import org.apache.camel.processor.interceptor.BacklogTracer;
-import org.apache.camel.util.MessageDump;
import org.apache.felix.gogo.commands.Argument;
import org.apache.felix.gogo.commands.Command;
-import org.apache.felix.gogo.commands.Option;
import org.apache.karaf.shell.console.OsgiCommandSupport;
/**
* Command to use the <a href="camel.apache.org/backlogtracer">Backlog Tracer</a>.
*/
-@Command(scope = "camel", name = "backlog-tracer", description = "Access the Backlog tracer")
-public class BacklogTracerCommand extends OsgiCommandSupport {
-
- @Option(name ="-a", aliases = {"--action"}, description = "The action to perform.", required = true, multiValued = false)
- String action;
+@Command(scope = "camel", name = "backlog-tracer-info", description = "Displays the current status of the Backlog tracer")
+public class BacklogTracerInfo extends OsgiCommandSupport {
@Argument(index = 0, name = "context", description = "The name of the Camel context.", required = true, multiValued = false)
String context;
- @Argument(index = 1, name = "pattern", description = "To trace/dump trace messages only for nodes matching the given pattern (default is all)", required = false, multiValued = false)
- String pattern;
-
- @Argument(index = 2, name = "format", description = "Format to use with the dump action (default is xml)", required = false, multiValued = false)
- String format;
-
- // TODO: need to work on a better command syntax to make it easier to use
-
private CamelController camelController;
public void setCamelController(CamelController camelController) {
@@ -71,67 +50,16 @@ public class BacklogTracerCommand extend
backlogTracer = (BacklogTracer) camel.getDefaultBacklogTracer();
}
- if ("enable".equals(action)) {
- backlogTracer.setEnabled(true);
- if (pattern != null) {
- backlogTracer.setTracePattern(pattern);
- System.out.println("BacklogTracer enabled on " + camel.getName() + " using pattern: " + pattern);
- } else {
- System.out.println("BacklogTracer enabled on " + camel.getName());
- }
- return null;
- } else if ("disable".equals(action)) {
- backlogTracer.setEnabled(false);
- backlogTracer.setTracePattern(null);
- System.out.println("BacklogTracer disabled on " + camel.getName());
- return null;
- } else if ("summary".equals(action)) {
- System.out.println("BacklogTracer context:" + camel.getName());
- System.out.println("BacklogTracer enabled:" + backlogTracer.isEnabled());
- System.out.println("BacklogTracer pattern:" + (backlogTracer.getTracePattern() != null ? backlogTracer.getTracePattern() : ""));
- System.out.println("BacklogTracer backlogSize:" + backlogTracer.getBacklogSize());
- System.out.println("BacklogTracer tracerCount:" + backlogTracer.getTraceCounter());
- return null;
- } else if ("dump".equals(action)) {
- if (format == null || "xml".equals(format)) {
- System.out.println("--------------------------------------------------------");
- System.out.println("BacklogTracer messages:\n" + backlogTracer.dumpAllTracedMessagesAsXml());
- return null;
- } else if ("table".equals(format)) {
- JAXBContext context = JAXBContext.newInstance(MessageDump.class);
- Unmarshaller unmarshaller = context.createUnmarshaller();
-
- // assume its a table
- SimpleDateFormat sdf = new SimpleDateFormat(BacklogTracerEventMessage.TIMESTAMP_FORMAT);
- List<BacklogTracerEventMessage> events = backlogTracer.dumpAllTracedMessages();
- for (BacklogTracerEventMessage event : events) {
- System.out.println("--------------------------------------------------------");
- System.out.println("#" + event.getUid() + "\tExchangeId: " + event.getExchangeId());
- System.out.println("Timestamp: " + sdf.format(event.getTimestamp()));
- System.out.println("Route: " + event.getRouteId() + " --> " + event.getToNode());
-
- MessageDump msg = (MessageDump) unmarshaller.unmarshal(new StringReader(event.getMessageAsXml()));
- String breadcrumb = getBreadcrumbId(msg.getHeaders());
- if (breadcrumb != null) {
- System.out.println("Breadcrumb: " + breadcrumb);
- }
- System.out.println("Body: " + msg.getBody().getValue());
- }
- }
- }
-
- return null;
- }
-
- private static String getBreadcrumbId(List<MessageDump.Header> headers) {
- if (headers == null || headers.isEmpty()) {
- return null;
- }
- for (MessageDump.Header header : headers) {
- if (header.getKey().equals(Exchange.BREADCRUMB_ID)) {
- return header.getValue();
- }
- }
+ System.out.println("BacklogTracer context:\t\t" + camel.getName());
+ System.out.println("BacklogTracer enabled:\t\t" + backlogTracer.isEnabled());
+ System.out.println("BacklogTracer pattern:\t\t" + (backlogTracer.getTracePattern() != null ? backlogTracer.getTracePattern() : ""));
+ System.out.println("BacklogTracer removeOnDump:\t" + backlogTracer.isRemoveOnDump());
+ System.out.println("BacklogTracer backlogSize:\t" + backlogTracer.getBacklogSize());
+ System.out.println("BacklogTracer tracerCount:\t" + backlogTracer.getTraceCounter());
+ System.out.println("BacklogTracer body...");
+ System.out.println("\tmaxChars:\t\t" + backlogTracer.getBodyMaxChars());
+ System.out.println("\tincludeFiles:\t\t" + backlogTracer.isBodyIncludeFiles());
+ System.out.println("\tincludeStreams:\t\t" + backlogTracer.isBodyIncludeStreams());
return null;
}
}
Copied: camel/trunk/platforms/karaf/commands/src/main/java/org/apache/camel/karaf/commands/BacklogTracerStart.java (from r1458241, camel/trunk/platforms/karaf/commands/src/main/java/org/apache/camel/karaf/commands/BacklogTracerCommand.java)
URL: http://svn.apache.org/viewvc/camel/trunk/platforms/karaf/commands/src/main/java/org/apache/camel/karaf/commands/BacklogTracerStart.java?p2=camel/trunk/platforms/karaf/commands/src/main/java/org/apache/camel/karaf/commands/BacklogTracerStart.java&p1=camel/trunk/platforms/karaf/commands/src/main/java/org/apache/camel/karaf/commands/BacklogTracerCommand.java&r1=1458241&r2=1458399&rev=1458399&view=diff
==============================================================================
--- camel/trunk/platforms/karaf/commands/src/main/java/org/apache/camel/karaf/commands/BacklogTracerCommand.java (original)
+++ camel/trunk/platforms/karaf/commands/src/main/java/org/apache/camel/karaf/commands/BacklogTracerStart.java Tue Mar 19 16:46:56 2013
@@ -16,17 +16,8 @@
*/
package org.apache.camel.karaf.commands;
-import java.io.StringReader;
-import java.text.SimpleDateFormat;
-import java.util.List;
-import javax.xml.bind.JAXBContext;
-import javax.xml.bind.Unmarshaller;
-
import org.apache.camel.CamelContext;
-import org.apache.camel.Exchange;
-import org.apache.camel.api.management.mbean.BacklogTracerEventMessage;
import org.apache.camel.processor.interceptor.BacklogTracer;
-import org.apache.camel.util.MessageDump;
import org.apache.felix.gogo.commands.Argument;
import org.apache.felix.gogo.commands.Command;
import org.apache.felix.gogo.commands.Option;
@@ -35,22 +26,24 @@ import org.apache.karaf.shell.console.Os
/**
* Command to use the <a href="camel.apache.org/backlogtracer">Backlog Tracer</a>.
*/
-@Command(scope = "camel", name = "backlog-tracer", description = "Access the Backlog tracer")
-public class BacklogTracerCommand extends OsgiCommandSupport {
-
- @Option(name ="-a", aliases = {"--action"}, description = "The action to perform.", required = true, multiValued = false)
- String action;
+@Command(scope = "camel", name = "backlog-tracer-start", description = "Starts the Backlog tracer")
+public class BacklogTracerStart extends OsgiCommandSupport {
- @Argument(index = 0, name = "context", description = "The name of the Camel context.", required = true, multiValued = false)
+ @Argument(index = 0, name = "context", description = "The name of the Camel context.",
+ required = true, multiValued = false)
String context;
- @Argument(index = 1, name = "pattern", description = "To trace/dump trace messages only for nodes matching the given pattern (default is all)", required = false, multiValued = false)
+ @Argument(index = 1, name = "pattern", description = "To trace messages only for nodes or routes matching the given pattern (default is all)",
+ required = false, multiValued = false)
String pattern;
- @Argument(index = 2, name = "format", description = "Format to use with the dump action (default is xml)", required = false, multiValued = false)
- String format;
-
- // TODO: need to work on a better command syntax to make it easier to use
+ @Option(name = "--backlogSize", aliases = "-s", description = "Number of maximum traced messages in total to keep in the backlog (FIFO queue)",
+ required = false, multiValued = false, valueToShowInHelp = "1000")
+ Integer backlogSize;
+
+ @Option(name = "--removeOnDump", aliases = "-r", description = "Whether to remove traced messages when dumping the messages",
+ required = false, multiValued = false)
+ Boolean removeOnDump;
private CamelController camelController;
@@ -71,67 +64,20 @@ public class BacklogTracerCommand extend
backlogTracer = (BacklogTracer) camel.getDefaultBacklogTracer();
}
- if ("enable".equals(action)) {
- backlogTracer.setEnabled(true);
- if (pattern != null) {
- backlogTracer.setTracePattern(pattern);
- System.out.println("BacklogTracer enabled on " + camel.getName() + " using pattern: " + pattern);
- } else {
- System.out.println("BacklogTracer enabled on " + camel.getName());
- }
- return null;
- } else if ("disable".equals(action)) {
- backlogTracer.setEnabled(false);
- backlogTracer.setTracePattern(null);
- System.out.println("BacklogTracer disabled on " + camel.getName());
- return null;
- } else if ("summary".equals(action)) {
- System.out.println("BacklogTracer context:" + camel.getName());
- System.out.println("BacklogTracer enabled:" + backlogTracer.isEnabled());
- System.out.println("BacklogTracer pattern:" + (backlogTracer.getTracePattern() != null ? backlogTracer.getTracePattern() : ""));
- System.out.println("BacklogTracer backlogSize:" + backlogTracer.getBacklogSize());
- System.out.println("BacklogTracer tracerCount:" + backlogTracer.getTraceCounter());
- return null;
- } else if ("dump".equals(action)) {
- if (format == null || "xml".equals(format)) {
- System.out.println("--------------------------------------------------------");
- System.out.println("BacklogTracer messages:\n" + backlogTracer.dumpAllTracedMessagesAsXml());
- return null;
- } else if ("table".equals(format)) {
- JAXBContext context = JAXBContext.newInstance(MessageDump.class);
- Unmarshaller unmarshaller = context.createUnmarshaller();
-
- // assume its a table
- SimpleDateFormat sdf = new SimpleDateFormat(BacklogTracerEventMessage.TIMESTAMP_FORMAT);
- List<BacklogTracerEventMessage> events = backlogTracer.dumpAllTracedMessages();
- for (BacklogTracerEventMessage event : events) {
- System.out.println("--------------------------------------------------------");
- System.out.println("#" + event.getUid() + "\tExchangeId: " + event.getExchangeId());
- System.out.println("Timestamp: " + sdf.format(event.getTimestamp()));
- System.out.println("Route: " + event.getRouteId() + " --> " + event.getToNode());
-
- MessageDump msg = (MessageDump) unmarshaller.unmarshal(new StringReader(event.getMessageAsXml()));
- String breadcrumb = getBreadcrumbId(msg.getHeaders());
- if (breadcrumb != null) {
- System.out.println("Breadcrumb: " + breadcrumb);
- }
- System.out.println("Body: " + msg.getBody().getValue());
- }
- }
+ backlogTracer.setEnabled(true);
+ if (backlogSize != null) {
+ backlogTracer.setBacklogSize(backlogSize);
}
-
- return null;
- }
-
- private static String getBreadcrumbId(List<MessageDump.Header> headers) {
- if (headers == null || headers.isEmpty()) {
- return null;
+ if (removeOnDump != null) {
+ backlogTracer.setRemoveOnDump(removeOnDump);
}
- for (MessageDump.Header header : headers) {
- if (header.getKey().equals(Exchange.BREADCRUMB_ID)) {
- return header.getValue();
- }
+ if (pattern != null) {
+ backlogTracer.setTracePattern(pattern);
+ System.out.println("BacklogTracer started on " + camel.getName() + " using pattern: " + pattern + " with size: " + backlogTracer.getBacklogSize());
+ } else {
+ System.out.println("BacklogTracer started on " + camel.getName() + " with size: " + backlogTracer.getBacklogSize());
}
return null;
}
+
}
Added: camel/trunk/platforms/karaf/commands/src/main/java/org/apache/camel/karaf/commands/BacklogTracerStop.java
URL: http://svn.apache.org/viewvc/camel/trunk/platforms/karaf/commands/src/main/java/org/apache/camel/karaf/commands/BacklogTracerStop.java?rev=1458399&view=auto
==============================================================================
--- camel/trunk/platforms/karaf/commands/src/main/java/org/apache/camel/karaf/commands/BacklogTracerStop.java (added)
+++ camel/trunk/platforms/karaf/commands/src/main/java/org/apache/camel/karaf/commands/BacklogTracerStop.java Tue Mar 19 16:46:56 2013
@@ -0,0 +1,58 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.apache.camel.karaf.commands;
+
+import org.apache.camel.CamelContext;
+import org.apache.camel.processor.interceptor.BacklogTracer;
+import org.apache.felix.gogo.commands.Argument;
+import org.apache.felix.gogo.commands.Command;
+import org.apache.karaf.shell.console.OsgiCommandSupport;
+
+/**
+ * Command to use the <a href="camel.apache.org/backlogtracer">Backlog Tracer</a>.
+ */
+@Command(scope = "camel", name = "backlog-tracer-stop", description = "Stops the Backlog tracer")
+public class BacklogTracerStop extends OsgiCommandSupport {
+
+ @Argument(index = 0, name = "context", description = "The name of the Camel context.", required = true, multiValued = false)
+ String context;
+
+ private CamelController camelController;
+
+ public void setCamelController(CamelController camelController) {
+ this.camelController = camelController;
+ }
+
+ @Override
+ protected Object doExecute() throws Exception {
+ CamelContext camel = camelController.getCamelContext(context);
+ if (camel == null) {
+ System.err.println("CamelContext " + context + " not found.");
+ return null;
+ }
+
+ BacklogTracer backlogTracer = BacklogTracer.getBacklogTracer(camel);
+ if (backlogTracer == null) {
+ backlogTracer = (BacklogTracer) camel.getDefaultBacklogTracer();
+ }
+
+ backlogTracer.setEnabled(false);
+ System.out.println("BacklogTracer stopped on " + camel.getName());
+ return null;
+ }
+
+}
Modified: camel/trunk/platforms/karaf/commands/src/main/resources/OSGI-INF/blueprint/camel-commands.xml
URL: http://svn.apache.org/viewvc/camel/trunk/platforms/karaf/commands/src/main/resources/OSGI-INF/blueprint/camel-commands.xml?rev=1458399&r1=1458398&r2=1458399&view=diff
==============================================================================
--- camel/trunk/platforms/karaf/commands/src/main/resources/OSGI-INF/blueprint/camel-commands.xml (original)
+++ camel/trunk/platforms/karaf/commands/src/main/resources/OSGI-INF/blueprint/camel-commands.xml Tue Mar 19 16:46:56 2013
@@ -122,8 +122,35 @@
<null/>
</completers>
</command>
- <command name="camel/backlog-tracer">
- <action class="org.apache.camel.karaf.commands.BacklogTracerCommand">
+ <command name="camel/backlog-tracer-info">
+ <action class="org.apache.camel.karaf.commands.BacklogTracerInfo">
+ <property name="camelController" ref="camelController"/>
+ </action>
+ <completers>
+ <ref component-id="camelContextCompleter"/>
+ <null/>
+ </completers>
+ </command>
+ <command name="camel/backlog-tracer-dump">
+ <action class="org.apache.camel.karaf.commands.BacklogTracerDump">
+ <property name="camelController" ref="camelController"/>
+ </action>
+ <completers>
+ <ref component-id="camelContextCompleter"/>
+ <null/>
+ </completers>
+ </command>
+ <command name="camel/backlog-tracer-start">
+ <action class="org.apache.camel.karaf.commands.BacklogTracerStart">
+ <property name="camelController" ref="camelController"/>
+ </action>
+ <completers>
+ <ref component-id="camelContextCompleter"/>
+ <null/>
+ </completers>
+ </command>
+ <command name="camel/backlog-tracer-stop">
+ <action class="org.apache.camel.karaf.commands.BacklogTracerStop">
<property name="camelController" ref="camelController"/>
</action>
<completers>