You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@brooklyn.apache.org by he...@apache.org on 2014/11/13 13:44:12 UTC
[05/10] incubator-brooklyn git commit: Restart sensor feed on mirror
entity rebind
Restart sensor feed on mirror entity rebind
Project: http://git-wip-us.apache.org/repos/asf/incubator-brooklyn/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-brooklyn/commit/3b386399
Tree: http://git-wip-us.apache.org/repos/asf/incubator-brooklyn/tree/3b386399
Diff: http://git-wip-us.apache.org/repos/asf/incubator-brooklyn/diff/3b386399
Branch: refs/heads/master
Commit: 3b386399a5f27a098b73170ca78dbcbf8ffd5466
Parents: 59208f5
Author: Svetoslav Neykov <sv...@cloudsoftcorp.com>
Authored: Thu Nov 13 10:54:05 2014 +0200
Committer: Svetoslav Neykov <sv...@cloudsoftcorp.com>
Committed: Thu Nov 13 10:54:05 2014 +0200
----------------------------------------------------------------------
.../brooklyn/entity/brooklynnode/BrooklynEntityMirrorImpl.java | 6 ++++++
1 file changed, 6 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-brooklyn/blob/3b386399/software/base/src/main/java/brooklyn/entity/brooklynnode/BrooklynEntityMirrorImpl.java
----------------------------------------------------------------------
diff --git a/software/base/src/main/java/brooklyn/entity/brooklynnode/BrooklynEntityMirrorImpl.java b/software/base/src/main/java/brooklyn/entity/brooklynnode/BrooklynEntityMirrorImpl.java
index b0fb728..80b19f5 100644
--- a/software/base/src/main/java/brooklyn/entity/brooklynnode/BrooklynEntityMirrorImpl.java
+++ b/software/base/src/main/java/brooklyn/entity/brooklynnode/BrooklynEntityMirrorImpl.java
@@ -68,6 +68,12 @@ public class BrooklynEntityMirrorImpl extends AbstractEntity implements Brooklyn
setAttribute(Attributes.SERVICE_STATE_ACTUAL, Lifecycle.STARTING);
}
+ @Override
+ public void rebind() {
+ super.rebind();
+ connectSensorsAsync();
+ }
+
protected void connectSensorsAsync() {
Callable<Void> asyncTask = new Callable<Void>() {
@Override