public class StormSshDriver extends JavaSoftwareProcessSshDriver implements StormDriver
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 |
|---|
StormSshDriver(EntityLocal entity,
SshMachineLocation machine) |
| Modifier and Type | Method and Description |
|---|---|
void |
customize() |
java.lang.String |
getJvmOptsLine() |
java.lang.String |
getLocalDir() |
java.lang.String |
getNimbusHostname() |
java.lang.String |
getPidFile() |
java.util.Map<java.lang.String,java.lang.Integer> |
getPortMap() |
java.lang.String |
getRoleName() |
java.lang.String |
getStormConfigTemplateUrl() |
java.lang.Integer |
getUiPort() |
java.lang.String |
getZeromqVersion() |
java.util.List<java.lang.String> |
getZookeeperServers() |
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, getShellEnvironment, 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, waitisJmxEnabledgetEntity, kill, rebind, restart, startgetLocationpublic StormSshDriver(EntityLocal entity, SshMachineLocation machine)
public java.lang.String getRoleName()
public java.lang.String getZeromqVersion()
public java.lang.String getLocalDir()
public java.lang.String getNimbusHostname()
public java.lang.Integer getUiPort()
public java.util.Map<java.lang.String,java.lang.Integer> getPortMap()
public java.lang.String getJvmOptsLine()
getJvmOptsLine in interface StormDriverpublic java.util.List<java.lang.String> getZookeeperServers()
public java.lang.String getStormConfigTemplateUrl()
public void preInstall()
AbstractSoftwareProcessDriverpreInstall in class AbstractSoftwareProcessDriverpublic void install()
install in class AbstractSoftwareProcessDriverpublic java.lang.String getPidFile()
public void launch()
launch in class AbstractSoftwareProcessDriverpublic boolean isRunning()
SoftwareProcessDriverisRunning in interface SoftwareProcessDriverpublic void stop()
SoftwareProcessDriverstop in interface SoftwareProcessDriverstop in class AbstractSoftwareProcessDriverStartable.stop()public void customize()
customize in class AbstractSoftwareProcessDriver