brooklyn.event.feed.ssh
[Java] Class SshFeed

java.lang.Object
  brooklyn.event.feed.AbstractFeed
      brooklyn.event.feed.ssh.SshFeed

public class SshFeed
extends AbstractFeed

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

 private SshFeed feed;
 
 //@Override
 protected void connectSensors() {
   super.connectSensors();
   
   feed = SshFeed.builder()
       .entity(this)
       .machine(mySshMachineLachine)
       .poll(new SshPollConfig(SERVICE_UP)
           .command("rabbitmqctl -q status")
           .onSuccess(new Function() {
               public Boolean apply(SshPollValue input) {
                 return (input.getExitStatus() == 0);
               }))
       .build();
 }
 
 {
literal:
@}Override
 protected void disconnectSensors() {
   super.disconnectSensors();
   if (feed != null) feed.stop();
 }
 }
 

Authors:

aled

log

public static final Logger log

SshFeed

protected java.lang.Object SshFeed(SshFeed.Builder builder)

builder

public static SshFeed.Builder builder()

getMachineOfEntity

public static SshMachineLocation getMachineOfEntity(Entity entity)

preStart

protected void preStart() {
protected void preStart()

Brooklyn Multi-Cloud Application Management Platform
brooklyncentral.github.com. Apache License. © 2012.