Repository: brooklyn-library Updated Branches: refs/heads/master cbb58b9ba -> 6efb209a4
minor fix to riak checking Project: http://git-wip-us.apache.org/repos/asf/brooklyn-library/repo Commit: http://git-wip-us.apache.org/repos/asf/brooklyn-library/commit/6efb209a Tree: http://git-wip-us.apache.org/repos/asf/brooklyn-library/tree/6efb209a Diff: http://git-wip-us.apache.org/repos/asf/brooklyn-library/diff/6efb209a Branch: refs/heads/master Commit: 6efb209a4f6d5e2d0286429869e3460311a0acdd Parents: cbb58b9 Author: Alex Heneveld <[email protected]> Authored: Sat Mar 5 00:55:52 2016 +0000 Committer: Alex Heneveld <[email protected]> Committed: Sat Mar 5 00:55:52 2016 +0000 ---------------------------------------------------------------------- .../java/org/apache/brooklyn/entity/nosql/riak/RiakClusterImpl.java | 1 + 1 file changed, 1 insertion(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/brooklyn-library/blob/6efb209a/software/nosql/src/main/java/org/apache/brooklyn/entity/nosql/riak/RiakClusterImpl.java ---------------------------------------------------------------------- diff --git a/software/nosql/src/main/java/org/apache/brooklyn/entity/nosql/riak/RiakClusterImpl.java b/software/nosql/src/main/java/org/apache/brooklyn/entity/nosql/riak/RiakClusterImpl.java index 8272815..3065015 100644 --- a/software/nosql/src/main/java/org/apache/brooklyn/entity/nosql/riak/RiakClusterImpl.java +++ b/software/nosql/src/main/java/org/apache/brooklyn/entity/nosql/riak/RiakClusterImpl.java @@ -204,6 +204,7 @@ public class RiakClusterImpl extends DynamicClusterImpl implements RiakCluster { DependentConfiguration.attributeWhenReady(member, RiakNode.RIAK_NODE_HAS_JOINED_CLUSTER, Predicates.equalTo(false)).blockUntilEnded(Duration.TWO_MINUTES); @SuppressWarnings("unchecked") Optional<Entity> anyNodeInCluster = Iterables.tryFind(nodes.keySet(), Predicates.and( + EntityPredicates.isManaged(), Predicates.instanceOf(RiakNode.class), EntityPredicates.attributeEqualTo(RiakNode.RIAK_NODE_HAS_JOINED_CLUSTER, true), Predicates.not(Predicates.equalTo(member))));
