AbstractfKafkaSshDriver (Brooklyn)

Overview

Package

Class

Deprecated

Index

Help

Brooklyn

FRAMES NO FRAMES

SUMMARY: NESTED | FIELD | CONSTR | METHOD

DETAIL: FIELD | CONSTR | METHOD

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

java.lang.Object
  brooklyn.entity.basic.AbstractSoftwareProcessDriver
      brooklyn.entity.basic.AbstractSoftwareProcessSshDriver
          brooklyn.entity.java.JavaSoftwareProcessSshDriver
              brooklyn.entity.messaging.kafka.AbstractfKafkaSshDriver

public abstract class AbstractfKafkaSshDriver
extends JavaSoftwareProcessSshDriver

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
`AbstractfKafkaSshDriver(EntityLocal entity, SshMachineLocation machine)`

Method Summary
`void`	`customize()`
`protected java.lang.String`	`getConfigFileName()`
`protected ConfigKey`	`getConfigTemplateKey()`
`protected java.util.List`	`getJmxJavaConfigOptions()`
`protected java.util.Map`	`getJmxJavaSystemProperties()`
`java.lang.String`	`getJmxRmiAgentJarBasename()`
`java.lang.String`	`getJmxRmiAgentJarDestinationFilePath()`
`java.lang.String`	`getJmxRmiAgentJarUrl()`
`protected java.lang.String`	`getLaunchScriptName()`
`protected java.lang.String`	`getLogFileLocation()`
`java.lang.String`	`getPidFile()`
`protected java.util.Map`	`getPortMap()`
`protected java.lang.String`	`getProcessIdentifier()`
`java.util.Map`	`getShellEnvironment()` Use RMI agent to provide JMX.
`void`	`install()`
`boolean`	`isRunning()`
`void`	`launch()`
`void`	`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 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

AbstractfKafkaSshDriver

public AbstractfKafkaSshDriver(EntityLocal entity, SshMachineLocation machine)

Method Detail

customize

@Override
public void customize()

getConfigFileName

protected java.lang.String getConfigFileName()

getConfigTemplateKey

protected ConfigKey getConfigTemplateKey()

getJmxJavaConfigOptions

@Override
protected java.util.List getJmxJavaConfigOptions()

getJmxJavaSystemProperties

@Override
protected java.util.Map getJmxJavaSystemProperties()

getJmxRmiAgentJarBasename

public java.lang.String getJmxRmiAgentJarBasename()

getJmxRmiAgentJarDestinationFilePath

public java.lang.String getJmxRmiAgentJarDestinationFilePath()

getJmxRmiAgentJarUrl

public java.lang.String getJmxRmiAgentJarUrl()

getLaunchScriptName

protected java.lang.String getLaunchScriptName()

getLogFileLocation

@Override
protected java.lang.String getLogFileLocation()

getPidFile

public java.lang.String getPidFile()

getPortMap

protected java.util.Map getPortMap()

getProcessIdentifier

protected java.lang.String getProcessIdentifier()

getShellEnvironment

@Override
public java.util.Map getShellEnvironment()

Use RMI agent to provide JMX.

install

@Override
public void install()

isRunning

@Override
public boolean isRunning()

launch

@Override
public void launch()

stop

@Override
public void stop()

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