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 2014/12/10 17:32:22 UTC
[12/15] camel git commit: CAMEL-8044: Camel commands should be more
reusable for remote JVMs
CAMEL-8044: Camel commands should be more reusable for remote JVMs
Project: http://git-wip-us.apache.org/repos/asf/camel/repo
Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/fcc877ab
Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/fcc877ab
Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/fcc877ab
Branch: refs/heads/master
Commit: fcc877ab755b4ea738d03a8bde363a1fec816d14
Parents: 8390076
Author: Claus Ibsen <da...@apache.org>
Authored: Wed Dec 10 15:21:05 2014 +0100
Committer: Claus Ibsen <da...@apache.org>
Committed: Wed Dec 10 15:21:05 2014 +0100
----------------------------------------------------------------------
.../org/apache/camel/management/mbean/ManagedRoute.java | 3 +++
.../main/java/org/apache/camel/util/RouteStatDump.java | 11 +++++++++++
.../java/org/apache/camel/commands/RouteInfoCommand.java | 1 +
3 files changed, 15 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/camel/blob/fcc877ab/camel-core/src/main/java/org/apache/camel/management/mbean/ManagedRoute.java
----------------------------------------------------------------------
diff --git a/camel-core/src/main/java/org/apache/camel/management/mbean/ManagedRoute.java b/camel-core/src/main/java/org/apache/camel/management/mbean/ManagedRoute.java
index 103d975..5b4a07a 100644
--- a/camel-core/src/main/java/org/apache/camel/management/mbean/ManagedRoute.java
+++ b/camel-core/src/main/java/org/apache/camel/management/mbean/ManagedRoute.java
@@ -323,10 +323,13 @@ public class ManagedRoute extends ManagedPerformanceCounter implements TimerList
routeSelfTime = 0;
}
+ int inflight = context.getInflightRepository().size(getRouteId());
+
StringBuilder answer = new StringBuilder();
answer.append("<routeStat").append(String.format(" id=\"%s\"", route.getId()));
// use substring as we only want the attributes
String stat = dumpStatsAsXml(fullStats);
+ answer.append(" exchangesInflight=\"").append(inflight).append("\"");
answer.append(" selfProcessingTime=\"").append(routeSelfTime).append("\"");
answer.append(" ").append(stat.substring(7, stat.length() - 2)).append(">\n");
http://git-wip-us.apache.org/repos/asf/camel/blob/fcc877ab/camel-core/src/main/java/org/apache/camel/util/RouteStatDump.java
----------------------------------------------------------------------
diff --git a/camel-core/src/main/java/org/apache/camel/util/RouteStatDump.java b/camel-core/src/main/java/org/apache/camel/util/RouteStatDump.java
index f1d09b6..7b171e0 100644
--- a/camel-core/src/main/java/org/apache/camel/util/RouteStatDump.java
+++ b/camel-core/src/main/java/org/apache/camel/util/RouteStatDump.java
@@ -66,6 +66,9 @@ public final class RouteStatDump {
private Long meanProcessingTime;
@XmlAttribute
+ private Long exchangesInflight;
+
+ @XmlAttribute
private Long selfProcessingTime;
@XmlAttribute
@@ -197,6 +200,14 @@ public final class RouteStatDump {
this.selfProcessingTime = selfProcessingTime;
}
+ public Long getExchangesInflight() {
+ return exchangesInflight;
+ }
+
+ public void setExchangesInflight(Long exchangesInflight) {
+ this.exchangesInflight = exchangesInflight;
+ }
+
public String getResetTimestamp() {
return resetTimestamp;
}
http://git-wip-us.apache.org/repos/asf/camel/blob/fcc877ab/platforms/commands/commands-core/src/main/java/org/apache/camel/commands/RouteInfoCommand.java
----------------------------------------------------------------------
diff --git a/platforms/commands/commands-core/src/main/java/org/apache/camel/commands/RouteInfoCommand.java b/platforms/commands/commands-core/src/main/java/org/apache/camel/commands/RouteInfoCommand.java
index eacfbb5..1c9acbc 100644
--- a/platforms/commands/commands-core/src/main/java/org/apache/camel/commands/RouteInfoCommand.java
+++ b/platforms/commands/commands-core/src/main/java/org/apache/camel/commands/RouteInfoCommand.java
@@ -64,6 +64,7 @@ public class RouteInfoCommand extends AbstractRouteCommand {
out.println(stringEscape.unescapeJava("\tExchanges Total: " + route.getExchangesCompleted() + route.getExchangesFailed()));
out.println(stringEscape.unescapeJava("\tExchanges Completed: " + route.getExchangesCompleted()));
out.println(stringEscape.unescapeJava("\tExchanges Failed: " + route.getExchangesFailed()));
+ out.println(stringEscape.unescapeJava("\tExchanges Inflight: " + route.getExchangesInflight()));
out.println(stringEscape.unescapeJava("\tMin Processing Time: " + route.getMinProcessingTime() + " ms"));
out.println(stringEscape.unescapeJava("\tMax Processing Time: " + route.getMaxProcessingTime() + " ms"));
out.println(stringEscape.unescapeJava("\tMean Processing Time: " + route.getMeanProcessingTime() + " ms"));