org.mule.module.launcher

Class DeploymentDirectoryWatcher

java.lang.Object

org.mule.module.launcher.DeploymentDirectoryWatcher

All Implemented Interfaces:

Runnable

Direct Known Subclasses:

ParallelDeploymentDirectoryWatcher

public class DeploymentDirectoryWatcher
extends Object
implements Runnable

It's in charge of the whole deployment process.

It will deploy the applications at the container startup process. It will periodically scan the artifact directories in order to process new deployments, remove artifacts that were previously deployed but the anchor file was removed and redeploy those applications which configuration has changed.

Field Summary

Fields

Modifier and Type	Field and Description
protected ArchiveDeployer<Application>	applicationArchiveDeployer
static String	ARTIFACT_ANCHOR_SUFFIX
static String	CHANGE_CHECK_INTERVAL_PROPERTY
protected static int	DEFAULT_CHANGES_CHECK_INTERVAL_MS
protected boolean	dirty
protected org.apache.commons.logging.Log	logger
static org.apache.commons.io.filefilter.IOFileFilter	ZIP_ARTIFACT_FILTER

Constructor Summary

Constructors

Constructor and Description
DeploymentDirectoryWatcher(ArchiveDeployer<Domain> domainArchiveDeployer, ArchiveDeployer<Application> applicationArchiveDeployer, ObservableList<Domain> domains, ObservableList<Application> applications, ReentrantLock deploymentLock)

Method Summary

Methods

Modifier and Type	Method and Description
protected void	deployExplodedApps(String[] apps)
protected void	deployPackedApps(String[] zips)
<T extends Artifact> T	findArtifact(String artifactName, ObservableList<T> artifacts)
void	run()
void	start() Starts the process of deployment / undeployment of artifact.
void	stop() Stops the deployment scan service.

Methods inherited from class java.lang.Object

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

Field Detail

ARTIFACT_ANCHOR_SUFFIX

public static final String ARTIFACT_ANCHOR_SUFFIX

See Also:

Constant Field Values

CHANGE_CHECK_INTERVAL_PROPERTY

public static final String CHANGE_CHECK_INTERVAL_PROPERTY

See Also:

Constant Field Values

ZIP_ARTIFACT_FILTER

public static final org.apache.commons.io.filefilter.IOFileFilter ZIP_ARTIFACT_FILTER

DEFAULT_CHANGES_CHECK_INTERVAL_MS

protected static final int DEFAULT_CHANGES_CHECK_INTERVAL_MS

See Also:

Constant Field Values

logger

protected final transient org.apache.commons.logging.Log logger

applicationArchiveDeployer

protected final ArchiveDeployer<Application> applicationArchiveDeployer

dirty

protected volatile boolean dirty

Constructor Detail

DeploymentDirectoryWatcher

public DeploymentDirectoryWatcher(ArchiveDeployer<Domain> domainArchiveDeployer,
                          ArchiveDeployer<Application> applicationArchiveDeployer,
                          ObservableList<Domain> domains,
                          ObservableList<Application> applications,
                          ReentrantLock deploymentLock)

Method Detail

start

public void start()

Starts the process of deployment / undeployment of artifact.

It wil schedule a task for periodically scan the deployment directories.

stop

public void stop()

Stops the deployment scan service.

deployPackedApps

protected void deployPackedApps(String[] zips)

deployExplodedApps

protected void deployExplodedApps(String[] apps)

run

public void run()

Specified by:

run in interface Runnable

findArtifact

public <T extends Artifact> T findArtifact(String artifactName,
                                  ObservableList<T> artifacts)