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 2017/10/06 08:06:32 UTC
[08/23] brooklyn-server git commit: task visibility: entity
initialization
task visibility: entity initialization
Project: http://git-wip-us.apache.org/repos/asf/brooklyn-server/repo
Commit: http://git-wip-us.apache.org/repos/asf/brooklyn-server/commit/e1f948ad
Tree: http://git-wip-us.apache.org/repos/asf/brooklyn-server/tree/e1f948ad
Diff: http://git-wip-us.apache.org/repos/asf/brooklyn-server/diff/e1f948ad
Branch: refs/heads/master
Commit: e1f948ad583af01138519a17a9d79d400ad0511a
Parents: 0a1acec
Author: Alex Heneveld <al...@cloudsoftcorp.com>
Authored: Tue Sep 19 13:19:39 2017 +0100
Committer: Alex Heneveld <al...@cloudsoftcorp.com>
Committed: Tue Sep 19 13:19:39 2017 +0100
----------------------------------------------------------------------
.../core/mgmt/internal/LocalSubscriptionManager.java | 9 +++++++--
1 file changed, 7 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/brooklyn-server/blob/e1f948ad/core/src/main/java/org/apache/brooklyn/core/mgmt/internal/LocalSubscriptionManager.java
----------------------------------------------------------------------
diff --git a/core/src/main/java/org/apache/brooklyn/core/mgmt/internal/LocalSubscriptionManager.java b/core/src/main/java/org/apache/brooklyn/core/mgmt/internal/LocalSubscriptionManager.java
index a9fb70b..65e4b14 100644
--- a/core/src/main/java/org/apache/brooklyn/core/mgmt/internal/LocalSubscriptionManager.java
+++ b/core/src/main/java/org/apache/brooklyn/core/mgmt/internal/LocalSubscriptionManager.java
@@ -145,8 +145,13 @@ public class LocalSubscriptionManager extends AbstractSubscriptionManager {
LOG.warn("Cannot notifyOfInitialValue for subscription with non-attribute sensor: "+s);
} else {
if (LOG.isTraceEnabled()) LOG.trace("sending initial value of {} -> {} to {}", new Object[] {s.producer, s.sensor, s});
- T val = (T) s.producer.getAttribute((AttributeSensor<?>) s.sensor);
- submitPublishEvent(s, new BasicSensorEvent<T>(s.sensor, s.producer, val), true);
+ em.submit(
+ MutableMap.of("tags", ImmutableList.of(BrooklynTaskTags.tagForContextEntity(s.producer)),
+ "displayName", "Initial publication of "+s.sensor.getName()),
+ () -> {
+ T val = (T) s.producer.getAttribute((AttributeSensor<?>) s.sensor);
+ submitPublishEvent(s, new BasicSensorEvent<T>(s.sensor, s.producer, val), true);
+ });
}
}