brooklyn-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From henev...@apache.org
Subject [4/7] brooklyn-server git commit: failure detector to use enricher's emit conveniences so highlights are recorded
Date Sat, 16 Sep 2017 01:52:03 GMT
failure detector to use enricher's emit conveniences so highlights are recorded


Project: http://git-wip-us.apache.org/repos/asf/brooklyn-server/repo
Commit: http://git-wip-us.apache.org/repos/asf/brooklyn-server/commit/5ae9a1bf
Tree: http://git-wip-us.apache.org/repos/asf/brooklyn-server/tree/5ae9a1bf
Diff: http://git-wip-us.apache.org/repos/asf/brooklyn-server/diff/5ae9a1bf

Branch: refs/heads/master
Commit: 5ae9a1bf8815e39637cb86d923c0ded76c6c3daf
Parents: 7170846
Author: Alex Heneveld <alex.heneveld@cloudsoftcorp.com>
Authored: Wed Sep 13 17:38:47 2017 +0100
Committer: Alex Heneveld <alex.heneveld@cloudsoftcorp.com>
Committed: Wed Sep 13 17:38:47 2017 +0100

----------------------------------------------------------------------
 .../org/apache/brooklyn/policy/ha/ServiceFailureDetector.java    | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/brooklyn-server/blob/5ae9a1bf/policy/src/main/java/org/apache/brooklyn/policy/ha/ServiceFailureDetector.java
----------------------------------------------------------------------
diff --git a/policy/src/main/java/org/apache/brooklyn/policy/ha/ServiceFailureDetector.java
b/policy/src/main/java/org/apache/brooklyn/policy/ha/ServiceFailureDetector.java
index 4cc0541..583c0ea 100644
--- a/policy/src/main/java/org/apache/brooklyn/policy/ha/ServiceFailureDetector.java
+++ b/policy/src/main/java/org/apache/brooklyn/policy/ha/ServiceFailureDetector.java
@@ -237,7 +237,7 @@ public class ServiceFailureDetector extends ServiceStateLogic.ComputeServiceStat
                         publishEntityFailedTime = now + republishDelay.toMilliseconds();
                         recomputeIn = Math.min(recomputeIn, republishDelay.toMilliseconds());
                     }
-                    entity.sensors().emit(HASensors.ENTITY_FAILED, new HASensors.FailureDescriptor(entity,
getFailureDescription(now)));
+                    emit(HASensors.ENTITY_FAILED, new HASensors.FailureDescriptor(entity,
getFailureDescription(now)));
                     config().set(LAST_PUBLISHED, LastPublished.FAILED);
                 } else {
                     recomputeIn = Math.min(recomputeIn, delayBeforeCheck);
@@ -248,7 +248,7 @@ public class ServiceFailureDetector extends ServiceStateLogic.ComputeServiceStat
                     if (LOG.isDebugEnabled()) LOG.debug("{} publishing recovered (state={};
currentRecoveryStartTime={}; now={}", 
                             new Object[] {this, state, Time.makeDateString(currentRecoveryStartTime),
Time.makeDateString(now)});
                     publishEntityRecoveredTime = null;
-                    entity.sensors().emit(HASensors.ENTITY_RECOVERED, new HASensors.FailureDescriptor(entity,
null));
+                    emit(HASensors.ENTITY_RECOVERED, new HASensors.FailureDescriptor(entity,
null));
                     config().set(LAST_PUBLISHED, LastPublished.RECOVERED);
                 } else {
                     recomputeIn = Math.min(recomputeIn, delayBeforeCheck);


Mime
View raw message