io.fabric8.process.manager.service

Class ProcessManagerService

java.lang.Object

io.fabric8.process.manager.service.ProcessManagerService

All Implemented Interfaces:

ProcessManager, ProcessManagerServiceMBean

public class ProcessManagerService
extends java.lang.Object
implements ProcessManagerServiceMBean

Constructor Summary

Constructors

Constructor and Description
ProcessManagerService()
ProcessManagerService(java.io.File storageLocation)

Method Summary

Methods

Modifier and Type	Method and Description
void	bindMBeanServer(javax.management.MBeanServer mbeanServer)
protected ProcessController	createController(int id, ProcessConfig config, java.io.File rootDir, java.io.File installDir)
protected Installation	createInstallation(int id, java.io.File rootDir, ProcessConfig config)
protected java.io.File	createInstallDir(int id)
protected int	createNextId() Returns the next process ID
protected void	downloadContent(java.net.URL url, java.io.File installDir)
java.util.concurrent.Executor	getExecutor()
java.io.File	getStorageLocation()
void	init()
Installation	install(InstallOptions options, InstallTask postInstall) Installs a process with an optional URL of the controller JSON together with an optional install step
Installation	installJar(InstallOptions parameters) Installs an executable jar as a new managed process
protected Installation	installViaScript(java.net.URL controllerUrl, InstallTask installTask)
com.google.common.collect.ImmutableMap<java.lang.Integer,Installation>	listInstallationMap()
com.google.common.collect.ImmutableList<Installation>	listInstallations() Returns the current installed processes which may or may not be running right now
protected ProcessConfig	loadControllerJson(java.net.URL controllerJson)
void	registerMBeanServer(javax.management.MBeanServer mbeanServer)
void	setExecutor(java.util.concurrent.Executor executor)
void	setStorageLocation(java.io.File storageLocation)
java.lang.String	toString()
void	unbindMBeanServer(javax.management.MBeanServer mbeanServer)
void	unregisterMBeanServer(javax.management.MBeanServer mbeanServer)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

ProcessManagerService

public ProcessManagerService()
                      throws javax.management.MalformedObjectNameException

Throws:

javax.management.MalformedObjectNameException

ProcessManagerService

public ProcessManagerService(java.io.File storageLocation)
                      throws javax.management.MalformedObjectNameException

Throws:

javax.management.MalformedObjectNameException

Method Detail

bindMBeanServer

public void bindMBeanServer(javax.management.MBeanServer mbeanServer)

unbindMBeanServer

public void unbindMBeanServer(javax.management.MBeanServer mbeanServer)

registerMBeanServer

public void registerMBeanServer(javax.management.MBeanServer mbeanServer)

unregisterMBeanServer

public void unregisterMBeanServer(javax.management.MBeanServer mbeanServer)

init

public void init()
          throws java.lang.Exception

Throws:

java.lang.Exception

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object

listInstallations

public com.google.common.collect.ImmutableList<Installation> listInstallations()

Description copied from interface: ProcessManager

Returns the current installed processes which may or may not be running right now

Specified by:

listInstallations in interface ProcessManager

listInstallationMap

public com.google.common.collect.ImmutableMap<java.lang.Integer,Installation> listInstallationMap()

Specified by:

listInstallationMap in interface ProcessManager

install

public Installation install(InstallOptions options,
                   InstallTask postInstall)
                     throws java.lang.Exception

Description copied from interface: ProcessManager

Installs a process with an optional URL of the controller JSON together with an optional install step

Specified by:

install in interface ProcessManager

Throws:

java.lang.Exception

installJar

public Installation installJar(InstallOptions parameters)
                        throws java.lang.Exception

Description copied from interface: ProcessManager

Installs an executable jar as a new managed process

Specified by:

installJar in interface ProcessManager

Throws:

java.lang.Exception

getStorageLocation

public java.io.File getStorageLocation()

setStorageLocation

public void setStorageLocation(java.io.File storageLocation)

getExecutor

public java.util.concurrent.Executor getExecutor()

setExecutor

public void setExecutor(java.util.concurrent.Executor executor)

installViaScript

protected Installation installViaScript(java.net.URL controllerUrl,
                            InstallTask installTask)
                                 throws java.lang.Exception

Throws:

java.lang.Exception

downloadContent

protected void downloadContent(java.net.URL url,
                   java.io.File installDir)
                        throws java.io.IOException,
                               CommandFailedException

Throws:

java.io.IOException

CommandFailedException

loadControllerJson

protected ProcessConfig loadControllerJson(java.net.URL controllerJson)
                                    throws java.io.IOException

Throws:

java.io.IOException

createNextId

protected int createNextId()

Returns the next process ID

createInstallDir

protected java.io.File createInstallDir(int id)

createInstallation

protected Installation createInstallation(int id,
                              java.io.File rootDir,
                              ProcessConfig config)

createController

protected ProcessController createController(int id,
                                 ProcessConfig config,
                                 java.io.File rootDir,
                                 java.io.File installDir)