Brooklyn

brooklyn.policy.ha
[Java] Class ServiceFailureDetector

java.lang.Object
  brooklyn.policy.basic.AbstractEntityAdjunct
      brooklyn.policy.basic.AbstractPolicy
          brooklyn.policy.ha.ServiceFailureDetector

public class ServiceFailureDetector
extends AbstractPolicy

attaches to a SoftwareProcess (or anything emitting SERVICE_UP and SERVICE_STATE) and emits HASensors.ENTITY_FAILED and ENTITY_RECOVERED as appropriate

See Also:
MemberFailureDetectionPolicy


Field Summary
static BasicNotificationSensor ENTITY_FAILED

static ConfigKey ONLY_REPORT_IF_PREVIOUSLY_UP

static ConfigKey SET_ON_FIRE_ON_FAILURE

static ConfigKey USE_SERVICE_STATE_RUNNING

protected java.util.concurrent.atomic.AtomicReference currentFailureStartTime

protected java.util.concurrent.atomic.AtomicReference serviceIsUp

protected java.util.concurrent.atomic.AtomicReference serviceLastUp

protected java.util.concurrent.atomic.AtomicReference serviceState

protected boolean weSetItOnFire

 
Fields inherited from class AbstractPolicy
policyStatus, suspended
 
Fields inherited from class AbstractEntityAdjunct
_subscriptionTracker, adjunctType, configsInternal, entity, execution, id, leftoverProperties, name
 
Constructor Summary
ServiceFailureDetector()

ServiceFailureDetector(java.util.Map flags)

ServiceFailureDetector(ConfigBag configBag)

 
Method Summary
void setEntity(EntityLocal entity)

 
Methods inherited from class AbstractPolicy
destroy, getPolicyType, getRebindSupport, isRunning, isSuspended, resume, suspend, toString
 
Methods inherited from class AbstractEntityAdjunct
check, configure, configure, destroy, doReconfigureConfig, getAdjunctType, getAllConfig, getAllSubscriptions, getConfig, getConfigMap, getId, getManagementContext, getName, getSubscriptionTracker, init, isDestroyed, isLegacyConstruction, isRunning, setConfig, setEntity, setId, setManagementContext, setName, subscribe, subscribeToChildren, subscribeToMembers, toString, unsubscribe, unsubscribe
 

Field Detail

ENTITY_FAILED

public static final BasicNotificationSensor ENTITY_FAILED


ONLY_REPORT_IF_PREVIOUSLY_UP

public static final ConfigKey USE_SERVICE_STATE_RUNNING = ConfigKeys.newBooleanConfigKey("useServiceStateRunning", "", true);
public static final ConfigKey ONLY_REPORT_IF_PREVIOUSLY_UP


SET_ON_FIRE_ON_FAILURE

protected final AtomicReference serviceLastUp = new AtomicReference();
public static final ConfigKey SET_ON_FIRE_ON_FAILURE


USE_SERVICE_STATE_RUNNING

public static final ConfigKey SET_ON_FIRE_ON_FAILURE = ConfigKeys.newBooleanConfigKey("setOnFireOnFailure", "", true);
public static final ConfigKey USE_SERVICE_STATE_RUNNING


currentFailureStartTime

protected final java.util.concurrent.atomic.AtomicReference currentFailureStartTime


serviceIsUp

protected final java.util.concurrent.atomic.AtomicReference serviceIsUp


serviceLastUp

protected final java.util.concurrent.atomic.AtomicReference serviceLastUp


serviceState

protected final java.util.concurrent.atomic.AtomicReference serviceState


weSetItOnFire

protected boolean weSetItOnFire


 
Constructor Detail

ServiceFailureDetector

public ServiceFailureDetector()


ServiceFailureDetector

public ServiceFailureDetector(java.util.Map flags)


ServiceFailureDetector

public ServiceFailureDetector(ConfigBag configBag)


 
Method Detail

setEntity

subscribe(entity, Attributes.SERVICE_STATE, new SensorEventListener() {
public void setEntity(EntityLocal entity)


 

Brooklyn Multi-Cloud Application Management Platform
brooklyncentral.github.com. Apache License. © 2012.