You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@brooklyn.apache.org by ri...@apache.org on 2014/10/14 12:04:59 UTC
[09/16] git commit: Fix MongoDB sharding
Fix MongoDB sharding
- onEntityAdded was using entity param rather than super.entity
Project: http://git-wip-us.apache.org/repos/asf/incubator-brooklyn/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-brooklyn/commit/d936ebdc
Tree: http://git-wip-us.apache.org/repos/asf/incubator-brooklyn/tree/d936ebdc
Diff: http://git-wip-us.apache.org/repos/asf/incubator-brooklyn/diff/d936ebdc
Branch: refs/heads/master
Commit: d936ebdc25f64c21ae640cedf945e4d1b83e3986
Parents: 10a3166
Author: Aled Sage <al...@gmail.com>
Authored: Mon Oct 13 21:13:53 2014 +0100
Committer: Aled Sage <al...@gmail.com>
Committed: Mon Oct 13 21:13:53 2014 +0100
----------------------------------------------------------------------
.../nosql/mongodb/sharding/MongoDBRouterClusterImpl.java | 6 +++---
1 file changed, 3 insertions(+), 3 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-brooklyn/blob/d936ebdc/software/nosql/src/main/java/brooklyn/entity/nosql/mongodb/sharding/MongoDBRouterClusterImpl.java
----------------------------------------------------------------------
diff --git a/software/nosql/src/main/java/brooklyn/entity/nosql/mongodb/sharding/MongoDBRouterClusterImpl.java b/software/nosql/src/main/java/brooklyn/entity/nosql/mongodb/sharding/MongoDBRouterClusterImpl.java
index 927113b..52fe525 100644
--- a/software/nosql/src/main/java/brooklyn/entity/nosql/mongodb/sharding/MongoDBRouterClusterImpl.java
+++ b/software/nosql/src/main/java/brooklyn/entity/nosql/mongodb/sharding/MongoDBRouterClusterImpl.java
@@ -56,13 +56,13 @@ public class MongoDBRouterClusterImpl extends DynamicClusterImpl implements Mong
public static class MemberTrackingPolicy extends AbstractMembershipTrackingPolicy {
@Override protected void onEntityEvent(EventType type, Entity entity) {
- ((MongoDBRouterClusterImpl)entity).setAnyRouter();
+ ((MongoDBRouterClusterImpl)super.entity).setAnyRouter();
}
@Override protected void onEntityRemoved(Entity member) {
- ((MongoDBRouterClusterImpl)entity).setAnyRouter();
+ ((MongoDBRouterClusterImpl)super.entity).setAnyRouter();
}
@Override protected void onEntityChange(Entity member) {
- ((MongoDBRouterClusterImpl)entity).setAnyRouter();
+ ((MongoDBRouterClusterImpl)super.entity).setAnyRouter();
}
}