public class SshFeed extends AbstractFeed
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 |
BrooklynObject.TagSupport| Modifier and Type | Field and Description |
|---|---|
static ConfigKey<java.lang.Boolean> |
EXEC_AS_COMMAND |
static org.slf4j.Logger |
log |
static ConfigKey<com.google.common.base.Supplier<SshMachineLocation>> |
MACHINE |
static ConfigKey<com.google.common.collect.SetMultimap<brooklyn.event.feed.ssh.SshFeed.SshPollIdentifier,SshPollConfig<?>>> |
POLLS |
ONLY_IF_SERVICE_UP| Constructor and Description |
|---|
SshFeed()
For rebind; do not call directly; use builder
|
| Modifier and Type | Method and Description |
|---|---|
static SshFeed.Builder |
builder() |
static SshMachineLocation |
getMachineOfEntity(Entity entity)
Deprecated.
since 0.7.0, use static convenience on
Locations |
destroy, getEntity, getRebindSupport, isActivated, isActive, isRunning, isSuspended, resume, setEntity, start, stop, suspendconfigure, getAllConfig, getConfig, getConfigMap, getDisplayName, getName, getUniqueTag, isDestroyed, setConfig, setDisplayName, setName, tags, toStringgetCatalogItemId, getId, getManagementContext, getTagSupport, init, rebind, setCatalogItemId, setManagementContextequals, getClass, hashCode, notify, notifyAll, wait, wait, waitgetId, getName, getUniqueTag, isDestroyedgetCatalogItemId, getDisplayName, getTagSupport, tagssetCatalogItemIdpublic static final org.slf4j.Logger log
public static final ConfigKey<com.google.common.base.Supplier<SshMachineLocation>> MACHINE
public static final ConfigKey<java.lang.Boolean> EXEC_AS_COMMAND
public static final ConfigKey<com.google.common.collect.SetMultimap<brooklyn.event.feed.ssh.SshFeed.SshPollIdentifier,SshPollConfig<?>>> POLLS
public static SshFeed.Builder builder()
@Deprecated public static SshMachineLocation getMachineOfEntity(Entity entity)
Locations