Repository: camel Updated Branches: refs/heads/camel-2.20.x cf32b912e -> b7ea17120
CAMEL-11902: cluster-service : FileLockClusterView should not always return local member as leader Project: http://git-wip-us.apache.org/repos/asf/camel/repo Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/b7ea1712 Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/b7ea1712 Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/b7ea1712 Branch: refs/heads/camel-2.20.x Commit: b7ea171209efdfef8a132c596772460a57bf365d Parents: cf32b91 Author: lburgazzoli <[email protected]> Authored: Thu Oct 12 18:52:50 2017 +0200 Committer: lburgazzoli <[email protected]> Committed: Thu Oct 12 18:56:03 2017 +0200 ---------------------------------------------------------------------- .../org/apache/camel/component/file/ha/FileLockClusterView.java | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/camel/blob/b7ea1712/camel-core/src/main/java/org/apache/camel/component/file/ha/FileLockClusterView.java ---------------------------------------------------------------------- diff --git a/camel-core/src/main/java/org/apache/camel/component/file/ha/FileLockClusterView.java b/camel-core/src/main/java/org/apache/camel/component/file/ha/FileLockClusterView.java index 6fcf703..cfcdab2 100644 --- a/camel-core/src/main/java/org/apache/camel/component/file/ha/FileLockClusterView.java +++ b/camel-core/src/main/java/org/apache/camel/component/file/ha/FileLockClusterView.java @@ -56,7 +56,9 @@ public class FileLockClusterView extends AbstractCamelClusterView { @Override public Optional<CamelClusterMember> getMaster() { - return Optional.of(this.localMember); + return this.localMember.isLeader() + ? Optional.of(this.localMember) + : Optional.empty(); } @Override
