CAMEL-7045: Fixed backlog tracer dump traced message to match node or route id.
Project: http://git-wip-us.apache.org/repos/asf/camel/repo Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/a351d3dc Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/a351d3dc Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/a351d3dc Branch: refs/heads/camel-2.12.x Commit: a351d3dcf399a3f55aa439b6e13339e20b3f8ffc Parents: ba7071b Author: Claus Ibsen <[email protected]> Authored: Fri Dec 6 11:00:07 2013 +0100 Committer: Claus Ibsen <[email protected]> Committed: Fri Dec 6 11:01:52 2013 +0100 ---------------------------------------------------------------------- .../java/org/apache/camel/processor/interceptor/BacklogTracer.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/camel/blob/a351d3dc/camel-core/src/main/java/org/apache/camel/processor/interceptor/BacklogTracer.java ---------------------------------------------------------------------- diff --git a/camel-core/src/main/java/org/apache/camel/processor/interceptor/BacklogTracer.java b/camel-core/src/main/java/org/apache/camel/processor/interceptor/BacklogTracer.java index 3c85755..cd825e5 100644 --- a/camel-core/src/main/java/org/apache/camel/processor/interceptor/BacklogTracer.java +++ b/camel-core/src/main/java/org/apache/camel/processor/interceptor/BacklogTracer.java @@ -268,7 +268,7 @@ public class BacklogTracer extends ServiceSupport implements InterceptStrategy { List<BacklogTracerEventMessage> answer = new ArrayList<BacklogTracerEventMessage>(); if (nodeId != null) { for (DefaultBacklogTracerEventMessage message : queue) { - if (nodeId.equals(message.getToNode())) { + if (nodeId.equals(message.getToNode()) || nodeId.equals(message.getRouteId())) { answer.add(message); } }
