Brooklyn

brooklyn.entity.messaging.kafka
[Java] Class KafkaBrokerSshDriver

java.lang.Object
  brooklyn.entity.basic.AbstractSoftwareProcessDriver
      brooklyn.entity.basic.AbstractSoftwareProcessSshDriver
          brooklyn.entity.java.JavaSoftwareProcessSshDriver
              brooklyn.entity.messaging.kafka.AbstractfKafkaSshDriver
                  brooklyn.entity.messaging.kafka.KafkaBrokerSshDriver
All Implemented Interfaces:
KafkaBrokerDriver

public class KafkaBrokerSshDriver
extends AbstractfKafkaSshDriver

Field Summary
 
Fields inherited from class JavaSoftwareProcessSshDriver
KEY_VAL_OPT_PREFIXES, MUTUALLY_EXCLUSIVE_OPTS, log
 
Fields inherited from class AbstractSoftwareProcessSshDriver
BROOKLYN_HOME_DIR, CHECK_RUNNING, CUSTOMIZING, DEFAULT_INSTALL_BASEDIR, DEFAULT_RUN_BASEDIR, IGNORE_ENTITY_SSH_FLAGS, INSTALLING, KILLING, LAUNCHING, NO_VERSION_INFO, PID_FILENAME, RESTARTING, STOPPING, USE_PID_FILE, log, logSsh
 
Fields inherited from class AbstractSoftwareProcessDriver
entity
 
Constructor Summary
KafkaBrokerSshDriver(KafkaBrokerImpl entity, SshMachineLocation machine)

 
Method Summary
protected java.lang.String getConfigFileName()

protected ConfigKey getConfigTemplateKey()

java.lang.Integer getKafkaPort()

protected java.lang.String getLaunchScriptName()

protected java.util.Map getPortMap()

protected java.lang.String getProcessIdentifier()

 
Methods inherited from class AbstractfKafkaSshDriver
customize, getConfigFileName, getConfigTemplateKey, getJmxJavaConfigOptions, getJmxJavaSystemProperties, getJmxRmiAgentJarBasename, getJmxRmiAgentJarDestinationFilePath, getJmxRmiAgentJarUrl, getLaunchScriptName, getLogFileLocation, getPidFile, getPortMap, getProcessIdentifier, getShellEnvironment, install, isRunning, launch, stop
 
Methods inherited from class JavaSoftwareProcessSshDriver
getCustomJavaConfigOptions, getCustomJavaSystemProperties, getJavaOpts, getJavaSystemProperties, getJmxContext, getJmxJavaConfigOptions, getJmxJavaSystemProperties, getJmxPort, getJmxSslSupport, getLogFileLocation, getRmiPort, getRmiServerPort, getShellEnvironment, installJava, installJmxSupport, isJmxEnabled, isJmxSslEnabled, start
 
Methods inherited from class AbstractSoftwareProcessSshDriver
copyFile, copyFile, copyFile, copyResource, copyResource, copyResource, copyResources, copyTemplate, copyTemplate, copyTemplates, execute, execute, getAddress, getDefaultVersion, getDownloadFileSuffix, getDownloadFilename, getEntityVersionLabel, getEntityVersionLabel, getHostname, getInstallDir, getLocation, getMachine, getPortsUsed, getRunDir, getShellEnvironment, getSshFlags, getVersion, newScript, newScript
 
Methods inherited from class AbstractSoftwareProcessDriver
customize, getEntity, getLocation, getResource, getResourceAsString, install, kill, launch, postLaunch, processTemplate, processTemplate, rebind, restart, start, stop, waitForConfigKey
 

Constructor Detail

KafkaBrokerSshDriver

public KafkaBrokerSshDriver(KafkaBrokerImpl entity, SshMachineLocation machine)


 
Method Detail

getConfigFileName

@Override
protected java.lang.String getConfigFileName()


getConfigTemplateKey

@Override
protected ConfigKey getConfigTemplateKey()


getKafkaPort

@Override
public java.lang.Integer getKafkaPort()


getLaunchScriptName

@Override
protected java.lang.String getLaunchScriptName()


getPortMap

@Override
protected java.util.Map getPortMap()


getProcessIdentifier

@Override
protected java.lang.String getProcessIdentifier()


 

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