org.apache.brooklyn.entity.messaging.kafka

Class KafkaBrokerSshDriver

java.lang.Object

org.apache.brooklyn.entity.software.base.AbstractSoftwareProcessDriver

org.apache.brooklyn.entity.software.base.AbstractSoftwareProcessSshDriver

org.apache.brooklyn.entity.java.JavaSoftwareProcessSshDriver

org.apache.brooklyn.entity.messaging.kafka.AbstractfKafkaSshDriver

org.apache.brooklyn.entity.messaging.kafka.KafkaBrokerSshDriver

All Implemented Interfaces:

EntityDriver, JavaSoftwareProcessDriver, KafkaBrokerDriver, NaiveScriptRunner, SoftwareProcessDriver

public class KafkaBrokerSshDriver
extends AbstractfKafkaSshDriver
implements KafkaBrokerDriver

Field Summary

Fields inherited from class org.apache.brooklyn.entity.java.JavaSoftwareProcessSshDriver

KEY_VAL_OPT_PREFIXES, MUTUALLY_EXCLUSIVE_OPTS

Fields inherited from class org.apache.brooklyn.entity.software.base.AbstractSoftwareProcessSshDriver

CHECK_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 Summary

Constructors

Constructor and Description
KafkaBrokerSshDriver(KafkaBrokerImpl entity, SshMachineLocation machine)

Method Summary

Modifier and Type	Method and Description
java.lang.Integer	getKafkaPort()
java.util.Map<java.lang.String,java.lang.String>	getShellEnvironment() Use RMI agent to provide JMX.
java.lang.String	getTopicsScriptName()

Methods inherited from class org.apache.brooklyn.entity.messaging.kafka.AbstractfKafkaSshDriver

customize, getPidFile, install, isRunning, launch, stop

Methods inherited from class org.apache.brooklyn.entity.java.JavaSoftwareProcessSshDriver

checkJavaHostnameBug, copyRuntimeResources, getJavaOpts, getJmxContext, getJmxPort, getRmiRegistryPort, installJava, installJmxSupport, isJmxEnabled, isJmxSslEnabled, setup

Methods inherited from class org.apache.brooklyn.entity.software.base.AbstractSoftwareProcessSshDriver

checkNoHostnameBug, copyCustomizeResources, copyInstallResources, copyPreInstallResources, copyResource, copyResource, execute, execute, execute, getAddress, getHostname, getLocation, getMachine, getPortsUsed, getSubnetAddress, getSubnetHostname, prepare, runPostCustomizeCommand, runPostInstallCommand, runPostLaunchCommand, runPreCustomizeCommand, runPreInstallCommand, runPreLaunchCommand

Methods inherited from class org.apache.brooklyn.entity.software.base.AbstractSoftwareProcessDriver

copyResource, copyResource, copyResource, copyResource, copyResource, copyResource, copyResource, copyTemplate, copyTemplate, copyTemplate, getArchiveNameFormat, getEntity, getExpandedInstallDir, getInstallDir, getResource, getResourceAsString, getRunDir, getVersion, kill, postLaunch, preInstall, processTemplate, processTemplate, processTemplate, processTemplate, processTemplateContents, processTemplateContents, rebind, restart, setExpandedInstallDir, start

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.brooklyn.entity.java.JavaSoftwareProcessDriver

isJmxEnabled

Methods inherited from interface org.apache.brooklyn.entity.software.base.SoftwareProcessDriver

getEntity, isRunning, kill, rebind, restart, start, stop

Methods inherited from interface org.apache.brooklyn.api.entity.drivers.EntityDriver

getLocation

Constructor Detail

KafkaBrokerSshDriver

public KafkaBrokerSshDriver(KafkaBrokerImpl entity,
                            SshMachineLocation machine)

Method Detail

getTopicsScriptName

public java.lang.String getTopicsScriptName()

getKafkaPort

public java.lang.Integer getKafkaPort()

Specified by:

getKafkaPort in interface KafkaBrokerDriver

getShellEnvironment

public java.util.Map<java.lang.String,java.lang.String> getShellEnvironment()

Description copied from class: AbstractfKafkaSshDriver

Use RMI agent to provide JMX.

Overrides:

getShellEnvironment in class AbstractfKafkaSshDriver

See Also:

SoftwareProcess.SHELL_ENVIRONMENT