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/278761b2 Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/278761b2 Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/278761b2 Branch: refs/heads/camel-gora Commit: 278761b29be3ea98cc1a4d85c5c7cf11cdea29ba Parents: d43c34b Author: Claus Ibsen <davscl...@apache.org> Authored: Fri Dec 6 11:00:07 2013 +0100 Committer: Claus Ibsen <davscl...@apache.org> Committed: Fri Dec 6 11:02:01 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/278761b2/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); } }
