public class SshFeed extends AbstractCommandFeed
private SshFeed feed;
//@Override
protected void connectSensors() {
super.connectSensors();
feed = SshFeed.builder()
.entity(this)
.machine(mySshMachineLachine)
.poll(new SshPollConfig<Boolean>(SERVICE_UP)
.command("rabbitmqctl -q status")
.onSuccess(new Function<SshPollValue, Boolean>() {
public Boolean apply(SshPollValue input) {
return (input.getExitStatus() == 0);
}}))
.build();
}
{@literal @}Override
protected void disconnectSensors() {
super.disconnectSensors();
if (feed != null) feed.stop();
}
| Modifier and Type | Class and Description |
|---|---|
static class |
SshFeed.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 org.slf4j.Logger |
log |
EXEC_AS_COMMAND, MACHINE, POLLSONLY_IF_SERVICE_UPHIGHLIGHT_NAME_LAST_ACTION, HIGHLIGHT_NAME_LAST_CONFIRMATION, HIGHLIGHT_NAME_LAST_VIOLATION, HIGHLIGHT_NAME_TRIGGERS| Constructor and Description |
|---|
SshFeed()
For rebind; do not call directly; use builder
|
SshFeed(SshFeed.Builder builder) |
| Modifier and Type | Method and Description |
|---|---|
static SshFeed.Builder |
builder() |
destroy, getEntity, getRebindSupport, isActivated, isRunning, isSuspended, relations, resume, setEntity, start, stop, suspendconfig, configure, getAdjunctType, getConfig, getDisplayName, getExecutionContext, getHighlights, getManagementContext, getUniqueTag, isDestroyed, setDisplayName, setHighlights, subscriptions, tags, toStringaddSearchPath, getCatalogItemId, getCatalogItemIdSearchPath, getId, init, rebind, setCatalogItemId, setCatalogItemIdAndSearchPath, setManagementContext, stackCatalogItemIdequals, getClass, hashCode, notify, notifyAll, wait, wait, waitgetHighlights, getId, getUniqueTag, isDestroyedgetCatalogItemId, getCatalogItemIdSearchPath, getDisplayName, subscriptions, tagsconfig, getConfigaddSearchPath, setCatalogItemId, setCatalogItemIdAndSearchPath, stackCatalogItemIdpublic SshFeed()
public SshFeed(SshFeed.Builder builder)
public static SshFeed.Builder builder()