ActiveMQSshDriver (Brooklyn)

Overview

Package

Class

Deprecated

Index

Help

Brooklyn

FRAMES NO FRAMES

SUMMARY: NESTED | FIELD | CONSTR | METHOD

DETAIL: FIELD | CONSTR | METHOD

brooklyn.entity.messaging.activemq
[Java] Class ActiveMQSshDriver

java.lang.Object
  brooklyn.entity.basic.AbstractSoftwareProcessDriver
      brooklyn.entity.basic.AbstractSoftwareProcessSshDriver
          brooklyn.entity.java.JavaSoftwareProcessSshDriver
              brooklyn.entity.messaging.activemq.ActiveMQSshDriver

All Implemented Interfaces:: ActiveMQDriver

public class ActiveMQSshDriver
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
`ActiveMQSshDriver(ActiveMQBrokerImpl entity, SshMachineLocation machine)`

Method Summary
`void`	`customize()`
`protected java.lang.String`	`getLogFileLocation()`
`java.lang.String`	`getMirrorUrl()`
`java.lang.Integer`	`getOpenWirePort()`
`java.lang.String`	`getPidFile()`
`java.util.Map`	`getShellEnvironment()`
`protected java.lang.String`	`getTemplateConfigurationUrl()`
`void`	`install()`
`boolean`	`isRunning()`
`void`	`kill()`
`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

ActiveMQSshDriver

public ActiveMQSshDriver(ActiveMQBrokerImpl entity, SshMachineLocation machine)

Method Detail

customize

@Override
public void customize()

getLogFileLocation

@Override
protected java.lang.String getLogFileLocation()

getMirrorUrl

public java.lang.String getMirrorUrl()

getOpenWirePort

@Override
public java.lang.Integer getOpenWirePort()

getPidFile

public java.lang.String getPidFile()

getShellEnvironment

.put("ACTIVEMQ_OPTS", orig.get("JAVA_OPTS") != null ? orig.get("JAVA_OPTS") : "")
public java.util.Map getShellEnvironment()

getTemplateConfigurationUrl

protected java.lang.String getTemplateConfigurationUrl()

install

@Override
public void install()

isRunning

newScript(ImmutableMap.of("usePidFile", getPidFile()), STOPPING).execute();
public boolean isRunning()

kill

Map orig = super.getShellEnvironment();
public void kill()

launch

).execute();
public void launch()

stop

newScript(ImmutableMap.of("usePidFile", getPidFile()), KILLING).execute();
public void stop()

brooklyn.entity.messaging.activemq [Java] Class ActiveMQSshDriver