Updated Branches: refs/heads/master 5b84ccd6e -> 24533f672
[JGroups] Improved logging. Project: http://git-wip-us.apache.org/repos/asf/camel/repo Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/24533f67 Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/24533f67 Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/24533f67 Branch: refs/heads/master Commit: 24533f6727c0400da0b7f3fcd294284cd5b95e56 Parents: 5b84ccd Author: Henryk Konsek <[email protected]> Authored: Thu Dec 26 21:54:46 2013 +0100 Committer: Henryk Konsek <[email protected]> Committed: Thu Dec 26 21:54:46 2013 +0100 ---------------------------------------------------------------------- .../apache/camel/component/jgroups/JGroupsFilters.java | 11 ++++++++++- 1 file changed, 10 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/camel/blob/24533f67/components/camel-jgroups/src/main/java/org/apache/camel/component/jgroups/JGroupsFilters.java ---------------------------------------------------------------------- diff --git a/components/camel-jgroups/src/main/java/org/apache/camel/component/jgroups/JGroupsFilters.java b/components/camel-jgroups/src/main/java/org/apache/camel/component/jgroups/JGroupsFilters.java index ae9a4d2..4063208 100644 --- a/components/camel-jgroups/src/main/java/org/apache/camel/component/jgroups/JGroupsFilters.java +++ b/components/camel-jgroups/src/main/java/org/apache/camel/component/jgroups/JGroupsFilters.java @@ -20,11 +20,15 @@ import org.apache.camel.Exchange; import org.apache.camel.Predicate; import org.jgroups.Address; import org.jgroups.View; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; import static org.apache.camel.component.jgroups.JGroupsEndpoint.HEADER_JGROUPS_CHANNEL_ADDRESS; public final class JGroupsFilters { + private static final Logger LOG = LoggerFactory.getLogger(JGroupsFilters.class); + private static final int COORDINATOR_NODE_INDEX = 0; private JGroupsFilters() { @@ -42,11 +46,16 @@ public final class JGroupsFilters { @Override public boolean matches(Exchange exchange) { Object body = exchange.getIn().getBody(); + LOG.debug("Filtering message {}.", body); if (body instanceof View) { View view = (View) body; + Address coordinatorNodeAddress = view.getMembers().get(COORDINATOR_NODE_INDEX); Address channelAddress = exchange.getIn().getHeader(HEADER_JGROUPS_CHANNEL_ADDRESS, Address.class); - return channelAddress.equals(view.getMembers().get(COORDINATOR_NODE_INDEX)); + LOG.debug("Comparing endpoint channel address {} against the coordinator node address {}.", + channelAddress, coordinatorNodeAddress); + return channelAddress.equals(coordinatorNodeAddress); } + LOG.debug("Body {} is not an instance of org.jgroups.View . Skipping filter.", body); return true; } };
