node.getAttribute(RiakNode.RIAK_NODE_IN_CLUSTER))? true : false;
</BUG>
}
});
<BUG>if (anyNodeInCluster.isPresent() && !member.getAttribute(RiakNode.RIAK_NODE_IN_CLUSTER))
Entities.invokeEffectorWithArgs(this, member, RiakNode.JOIN_RIAK_CLUSTER, (RiakNode)anyNodeInCluster.get());

else
log.error("entity {}: is not present",member.getId());
}</BUG>
nodes.put(member, riakName);

((EntityInternal) member).setAttribute(RiakNode.RIAK_NODE_IN_CLUSTER, Boolean.TRUE);
isFirstNodeSet.set(true);
} else {
Optional<Entity> anyNodeInCluster = Iterables.tryFind(nodes.keySet(), new Predicate<Entity>() {
@Override
public boolean apply(@Nullable Entity node) {
return (node instanceof RiakNode && node.getAttribute(RiakNode.RIAK_NODE_IN_CLUSTER)) ? true : false;
}
});
if (anyNodeInCluster.isPresent()) {
if (!isMemberInCluster(member)) {
Entities.invokeEffectorWithArgs(this, member, RiakNode.JOIN_RIAK_CLUSTER, (RiakNode) anyNodeInCluster.get());
