public abstract class AbstractfKafkaSshDriver extends JavaSoftwareProcessSshDriver
KEY_VAL_OPT_PREFIXES, MUTUALLY_EXCLUSIVE_OPTSCHECK_RUNNING, CUSTOMIZING, DEBUG, IGNORE_ENTITY_SSH_FLAGS, INSTALL_INCOMPLETE, INSTALLING, KILLING, LAUNCHING, logSsh, NON_STANDARD_LAYOUT, PID_FILENAME, PROCESS_OWNER, RESTARTING, STOPPING, USE_PID_FILE, VALID_FLAGS| Constructor and Description |
|---|
AbstractfKafkaSshDriver(EntityLocal entity,
SshMachineLocation machine) |
| Modifier and Type | Method and Description |
|---|---|
void |
customize() |
java.lang.String |
getPidFile() |
java.util.Map<java.lang.String,java.lang.String> |
getShellEnvironment()
Use RMI agent to provide JMX.
|
void |
install() |
boolean |
isRunning()
Whether the entity components have started.
|
void |
launch() |
void |
preInstall()
Implement this method in child classes to add some pre-install behavior
|
void |
stop()
Performs software stop (or queues tasks to do this)
|
checkJavaHostnameBug, copyRuntimeResources, getJavaOpts, getJmxContext, getJmxPort, getRmiRegistryPort, installJava, installJmxSupport, isJmxEnabled, isJmxSslEnabled, setupcheckNoHostnameBug, copyInstallResources, copyResource, copyResource, execute, execute, execute, getAddress, getExpandedInstallDir, getHostname, getInstallDir, getLocation, getMachine, getPortsUsed, getRunDir, getSubnetAddress, getSubnetHostname, runPostInstallCommand, runPostLaunchCommand, runPreInstallCommand, runPreLaunchCommand, setExpandedInstallDircopyPreInstallResources, copyResource, copyResource, copyResource, copyResource, copyResource, copyResource, copyResource, copyTemplate, copyTemplate, copyTemplate, getEntity, getResource, getResourceAsString, getVersion, kill, postLaunch, processTemplate, processTemplate, processTemplate, processTemplate, processTemplateContents, processTemplateContents, rebind, restart, startequals, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitgetEntity, kill, rebind, restart, startgetLocationpublic AbstractfKafkaSshDriver(EntityLocal entity, SshMachineLocation machine)
public void preInstall()
AbstractSoftwareProcessDriverpreInstall in class AbstractSoftwareProcessDriverpublic void install()
install in class AbstractSoftwareProcessDriverpublic void customize()
customize in class AbstractSoftwareProcessDriverpublic void launch()
launch in class AbstractSoftwareProcessDriverpublic java.lang.String getPidFile()
public boolean isRunning()
SoftwareProcessDriverpublic void stop()
SoftwareProcessDriverstop in interface SoftwareProcessDriverstop in class AbstractSoftwareProcessDriverStartable.stop()public java.util.Map<java.lang.String,java.lang.String> getShellEnvironment()
getShellEnvironment in class JavaSoftwareProcessSshDriverSoftwareProcess.SHELL_ENVIRONMENT