org.mule.module.launcher
Class DeploymentDirectoryWatcher

java.lang.Object
  org.mule.module.launcher.DeploymentDirectoryWatcher

All Implemented Interfaces:

Runnable

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

static String	ARTIFACT_ANCHOR_SUFFIX
static String	CHANGE_CHECK_INTERVAL_PROPERTY
protected static int	DEFAULT_CHANGES_CHECK_INTERVAL_MS
protected boolean	dirty
protected Log	logger
static org.apache.commons.io.filefilter.IOFileFilter	ZIP_ARTIFACT_FILTER

Constructor Summary

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

Method Summary

<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 Log logger

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.

run

public void run()

Specified by:

run in interface Runnable

findArtifact

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