org.apache.brooklyn.feed

Class AbstractCommandFeed

java.lang.Object

org.apache.brooklyn.core.objs.AbstractBrooklynObject

org.apache.brooklyn.core.objs.AbstractEntityAdjunct

org.apache.brooklyn.core.feed.AbstractFeed

org.apache.brooklyn.feed.AbstractCommandFeed

All Implemented Interfaces:

Rebindable, BrooklynObject, Configurable, EntityAdjunct, Identifiable, Feed, BrooklynObjectInternal

Direct Known Subclasses:

CmdFeed, SshFeed

public abstract class AbstractCommandFeed
extends AbstractFeed

Provides a feed of attribute values, by polling over Command Line Shell Interface. Example usage (e.g. in an entity that extends SoftwareProcessImpl):

 
 private AbstractCommandFeed feed;
 
 //@Override
 protected void connectSensors() {
   super.connectSensors();
   
   feed = SshFeed.builder()
       .entity(this)
       .machine(mySshMachineLachine)
       .poll(new CommandPollConfig<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();
 }
 
 

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	AbstractCommandFeed.Builder<T extends AbstractCommandFeed,B extends AbstractCommandFeed.Builder<T,B>>

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 ConfigKey<java.lang.Boolean>	EXEC_AS_COMMAND
static org.slf4j.Logger	log
static ConfigKey<com.google.common.base.Supplier<MachineLocation>>	MACHINE
static ConfigKey<com.google.common.collect.SetMultimap<org.apache.brooklyn.feed.AbstractCommandFeed.CommandPollIdentifier,CommandPollConfig<?>>>	POLLS

Fields inherited from class org.apache.brooklyn.core.feed.AbstractFeed

ONLY_IF_SERVICE_UP

Constructor Summary

Constructors

Constructor and Description
AbstractCommandFeed() For rebind; do not call directly; use builder

Method Summary

Methods inherited from class org.apache.brooklyn.core.feed.AbstractFeed

destroy, getEntity, getRebindSupport, isActivated, isRunning, isSuspended, relations, resume, setEntity, start, stop, suspend

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

config, configure, getAdjunctType, getConfig, getDisplayName, getUniqueTag, isDestroyed, setConfig, setDisplayName, subscribe, subscribeToChildren, subscribeToMembers, subscriptions, tags, toString, unsubscribe, unsubscribe

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

getCatalogItemId, getId, getManagementContext, init, rebind, setCatalogItemId, setManagementContext

Methods inherited from class java.lang.Object

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

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

getId, getUniqueTag, isDestroyed

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

getCatalogItemId, getDisplayName, subscriptions, tags

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

config, getConfig, setConfig

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

setCatalogItemId

Field Detail

log

public static final org.slf4j.Logger log

MACHINE

public static final ConfigKey<com.google.common.base.Supplier<MachineLocation>> MACHINE

EXEC_AS_COMMAND

public static final ConfigKey<java.lang.Boolean> EXEC_AS_COMMAND

POLLS

public static final ConfigKey<com.google.common.collect.SetMultimap<org.apache.brooklyn.feed.AbstractCommandFeed.CommandPollIdentifier,CommandPollConfig<?>>> POLLS

Constructor Detail

AbstractCommandFeed

public AbstractCommandFeed()

For rebind; do not call directly; use builder