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, location, resource

Constructor Summary
`AbstractfKafkaSshDriver(EntityLocal entity, SshMachineLocation machine)`

Method Summary
`void`	`customize()`
`protected java.lang.String`	`getConfigFileName()`
`protected ConfigKey`	`getConfigTemplateKey()`
`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()`
`protected boolean`	`isV08()`
`void`	`launch()`
`void`	`stop()`

Methods inherited from class JavaSoftwareProcessSshDriver
checkJavaHostnameBug, getCustomJavaConfigOptions, getCustomJavaSystemProperties, getJavaOpts, getJavaSystemProperties, getJmxContext, getJmxJavaConfigOptions, getJmxJavaSystemProperties, getJmxPort, getLogFileLocation, getRmiPort, getRmiRegistryPort, getRmiServerPort, getShellEnvironment, installJava, installJmxSupport, isJmxEnabled, isJmxSslEnabled, start

Methods inherited from class AbstractSoftwareProcessSshDriver
copyFile, copyFile, copyFile, copyResource, copyResource, copyResource, copyResources, copyTemplate, 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, 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, doFullStartOnRestart, getEntity, getLocation, getResource, getResourceAsString, install, kill, launch, postLaunch, processTemplate, processTemplate, processTemplate, processTemplate, processTemplateContents, processTemplateContents, rebind, restart, start, stop, waitForConfigKey

Constructor Detail

AbstractfKafkaSshDriver

public AbstractfKafkaSshDriver(EntityLocal entity, SshMachineLocation machine)

Method Detail

customize

public void customize() {
public void customize()

getConfigFileName

protected java.lang.String getConfigFileName()

getConfigTemplateKey

protected ConfigKey getConfigTemplateKey()

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

public Map getShellEnvironment() {
public java.util.Map getShellEnvironment()

Use RMI agent to provide JMX.

install

@Override
public void install()

isRunning

public boolean isRunning() {
public boolean isRunning()

isV08

protected boolean isV08()

launch

public void launch() {
public void launch()

stop

public void stop() {
public void stop()

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