org.apache.brooklyn.policy.ha

Class ConnectionFailureDetector

java.lang.Object

org.apache.brooklyn.core.objs.AbstractBrooklynObject

org.apache.brooklyn.core.objs.AbstractEntityAdjunct

org.apache.brooklyn.core.policy.AbstractPolicy

org.apache.brooklyn.policy.ha.AbstractFailureDetector

org.apache.brooklyn.policy.ha.ConnectionFailureDetector

All Implemented Interfaces:

Rebindable, BrooklynObject, Configurable, EntityAdjunct, Identifiable, Policy, BrooklynObjectInternal

public class ConnectionFailureDetector
extends AbstractFailureDetector

Monitors a given HostAndPort, to emit HASensors.CONNECTION_FAILED and HASensors.CONNECTION_RECOVERED if the connection is lost/restored.

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.brooklyn.policy.ha.AbstractFailureDetector

AbstractFailureDetector.CalculatedStatus, AbstractFailureDetector.LastPublished

Nested classes/interfaces inherited from class org.apache.brooklyn.core.objs.AbstractEntityAdjunct

AbstractEntityAdjunct.AdjunctTagSupport, AbstractEntityAdjunct.BasicSubscriptionSupport

Nested classes/interfaces inherited from interface org.apache.brooklyn.api.objs.BrooklynObject

BrooklynObject.RelationSupport<T extends BrooklynObject>, BrooklynObject.SubscriptionSupport, BrooklynObject.TagSupport

Nested classes/interfaces inherited from interface org.apache.brooklyn.api.objs.Configurable

Configurable.ConfigurationSupport

Nested classes/interfaces inherited from interface org.apache.brooklyn.core.objs.BrooklynObjectInternal

BrooklynObjectInternal.ConfigurationSupportInternal, BrooklynObjectInternal.RelationSupportInternal<T extends BrooklynObject>, BrooklynObjectInternal.SubscriptionSupportInternal

Field Summary

Fields

Modifier and Type	Field and Description
static BasicNotificationSensor<HASensors.FailureDescriptor>	CONNECTION_FAILED
static ConfigKey<Duration>	CONNECTION_FAILED_STABILIZATION_DELAY
static BasicNotificationSensor<HASensors.FailureDescriptor>	CONNECTION_RECOVERED
static ConfigKey<Duration>	CONNECTION_RECOVERED_STABILIZATION_DELAY
static ConfigKey<HostAndPort>	ENDPOINT
static ConfigKey<Duration>	POLL_PERIOD

Fields inherited from class org.apache.brooklyn.policy.ha.AbstractFailureDetector

FAILED_STABILIZATION_DELAY, RECOVERED_STABILIZATION_DELAY, SENSOR_FAILED, SENSOR_RECOVERED

Fields inherited from class org.apache.brooklyn.core.objs.AbstractEntityAdjunct

HIGHLIGHT_NAME_LAST_ACTION, HIGHLIGHT_NAME_LAST_CONFIRMATION, HIGHLIGHT_NAME_LAST_VIOLATION, HIGHLIGHT_NAME_TRIGGERS

Constructor Summary

Constructors

Constructor and Description
ConnectionFailureDetector()

Method Summary

Modifier and Type	Method and Description
void	init() Called by framework (in new-style instances where spec was used) after configuring etc, but before a reference to this instance is shared.

Methods inherited from class org.apache.brooklyn.policy.ha.AbstractFailureDetector

resume, setEntity, suspend

Methods inherited from class org.apache.brooklyn.core.policy.AbstractPolicy

destroy, getPolicyType, getRebindSupport, isRunning, isSuspended, relations, toString

Methods inherited from class org.apache.brooklyn.core.objs.AbstractEntityAdjunct

config, configure, getAdjunctType, getConfig, getDisplayName, getEntity, getExecutionContext, getHighlights, getManagementContext, getUniqueTag, isDestroyed, setDisplayName, setHighlights, subscriptions, tags

Methods inherited from class org.apache.brooklyn.core.objs.AbstractBrooklynObject

addSearchPath, getCatalogItemId, getCatalogItemIdSearchPath, getId, rebind, setCatalogItemId, setCatalogItemIdAndSearchPath, setManagementContext, stackCatalogItemId

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface org.apache.brooklyn.api.policy.Policy

getId

Methods inherited from interface org.apache.brooklyn.api.objs.EntityAdjunct

getHighlights, getUniqueTag, isDestroyed

Methods inherited from interface org.apache.brooklyn.api.objs.BrooklynObject

getCatalogItemId, getCatalogItemIdSearchPath, getDisplayName, subscriptions, tags

Methods inherited from interface org.apache.brooklyn.api.objs.Configurable

config, getConfig

Methods inherited from interface org.apache.brooklyn.core.objs.BrooklynObjectInternal

addSearchPath, setCatalogItemId, setCatalogItemIdAndSearchPath, stackCatalogItemId

Field Detail

ENDPOINT

public static final ConfigKey<HostAndPort> ENDPOINT

POLL_PERIOD

public static final ConfigKey<Duration> POLL_PERIOD

CONNECTION_FAILED

public static final BasicNotificationSensor<HASensors.FailureDescriptor> CONNECTION_FAILED

CONNECTION_RECOVERED

public static final BasicNotificationSensor<HASensors.FailureDescriptor> CONNECTION_RECOVERED

CONNECTION_FAILED_STABILIZATION_DELAY

public static final ConfigKey<Duration> CONNECTION_FAILED_STABILIZATION_DELAY

CONNECTION_RECOVERED_STABILIZATION_DELAY

public static final ConfigKey<Duration> CONNECTION_RECOVERED_STABILIZATION_DELAY

Constructor Detail

ConnectionFailureDetector

public ConnectionFailureDetector()

Method Detail

init

public void init()

Description copied from class: AbstractBrooklynObject

Called by framework (in new-style instances where spec was used) after configuring etc, but before a reference to this instance is shared.

To preserve backwards compatibility for if the instance is constructed directly, one can call the code below, but that means it will be called after references to this policy have been shared with other entities.

 
 if (isLegacyConstruction()) {
     init();
 }
 
 

Overrides:

init in class AbstractBrooklynObject