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.BasicSubscriptionSupportBrooklynObject.RelationSupport<T extends BrooklynObject>, BrooklynObject.SubscriptionSupport, BrooklynObject.TagSupportConfigurable.ConfigurationSupportBrooklynObjectInternal.ConfigurationSupportInternal, BrooklynObjectInternal.RelationSupportInternal<T extends BrooklynObject>, BrooklynObjectInternal.SubscriptionSupportInternal| Modifier and Type | Field and Description |
|---|---|
static ConfigKey< |
POLLS |
ONLY_IF_SERVICE_UP| 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, suspendconfig, configure, getAdjunctType, getConfig, getConfigMap, getDisplayName, getUniqueTag, isDestroyed, setConfig, setDisplayName, subscribe, subscribeToChildren, subscribeToMembers, subscriptions, tags, toString, unsubscribe, unsubscribegetCatalogItemId, getId, getManagementContext, init, rebind, setCatalogItemId, setManagementContextequals, getClass, hashCode, notify, notifyAll, wait, wait, waitgetId, getUniqueTag, isDestroyedgetCatalogItemId, getDisplayName, subscriptions, tagsconfig, getConfig, setConfigsetCatalogItemIdpublic static final ConfigKey<> POLLS
public static FunctionFeed.Builder builder()
public static FunctionFeed.Builder builder(java.lang.String uniqueTag)