public class FunctionFeed extends AbstractFeed
private FunctionFeed feed;
//@Override
protected void connectSensors() {
super.connectSensors();
feed = FunctionFeed.builder()
.entity(this)
.poll(new FunctionPollConfig<Object, Boolean>(SERVICE_UP)
.period(500, TimeUnit.MILLISECONDS)
.callable(new Callable<Boolean>() {
public Boolean call() throws Exception {
return getDriver().isRunning();
}
})
.onExceptionOrFailure(Functions.constant(Boolan.FALSE))
.build();
}
{@literal @}Override
protected void disconnectSensors() {
super.disconnectSensors();
if (feed != null) feed.stop();
}
Modifier and Type | Class and Description |
---|---|
static class |
FunctionFeed.Builder |
AbstractEntityAdjunct.AdjunctTagSupport, AbstractEntityAdjunct.BasicSubscriptionSupport
BrooklynObject.RelationSupport<T extends BrooklynObject>, BrooklynObject.SubscriptionSupport, BrooklynObject.TagSupport
Configurable.ConfigurationSupport
BrooklynObjectInternal.ConfigurationSupportInternal, BrooklynObjectInternal.RelationSupportInternal<T extends BrooklynObject>, BrooklynObjectInternal.SubscriptionSupportInternal
Modifier and Type | Field and Description |
---|---|
static ConfigKey<<any>> |
POLLS |
ONLY_IF_SERVICE_UP
HIGHLIGHT_NAME_LAST_ACTION, HIGHLIGHT_NAME_LAST_CONFIRMATION, HIGHLIGHT_NAME_LAST_VIOLATION, HIGHLIGHT_NAME_TRIGGERS
Constructor and Description |
---|
FunctionFeed()
For rebind; do not call directly; use builder
|
Modifier and Type | Method and Description |
---|---|
static FunctionFeed.Builder |
builder() |
static FunctionFeed.Builder |
builder(java.lang.String uniqueTag) |
destroy, getEntity, getRebindSupport, isActivated, isRunning, isSuspended, relations, resume, setEntity, start, stop, suspend
config, configure, getAdjunctType, getConfig, getDisplayName, getExecutionContext, getHighlights, getManagementContext, getUniqueTag, isDestroyed, setDisplayName, setHighlights, subscriptions, tags, toString
addSearchPath, getCatalogItemId, getCatalogItemIdSearchPath, getId, init, rebind, setCatalogItemId, setCatalogItemIdAndSearchPath, setManagementContext, stackCatalogItemId
equals, getClass, hashCode, notify, notifyAll, wait, wait, wait
getHighlights, getId, getUniqueTag, isDestroyed
getCatalogItemId, getCatalogItemIdSearchPath, getDisplayName, subscriptions, tags
config, getConfig
addSearchPath, setCatalogItemId, setCatalogItemIdAndSearchPath, stackCatalogItemId
public static final ConfigKey<<any>> POLLS
public static FunctionFeed.Builder builder()
public static FunctionFeed.Builder builder(java.lang.String uniqueTag)