You are viewing a plain text version of this content. The canonical link for it is here.
Posted to cvs@avalon.apache.org by do...@apache.org on 2002/09/13 12:26:12 UTC
cvs commit: jakarta-avalon-phoenix/src/java/org/apache/avalon/phoenix/components/monitor DefaultDeploymentMonitor.java Resources.properties
donaldp 2002/09/13 03:26:12
Modified: src/conf kernel.xml
Added: lib/container excalibur-monitor-1.0.jar
src/java/org/apache/avalon/phoenix/components/monitor
DefaultDeploymentMonitor.java Resources.properties
Log:
Add a monitor for the deployment directory. This component will monitor the dpeloyment directory and
If .sar file is added to directory it will be deployed.
If .sar file is removed from directory it will be undeployed.
If .sar file is modified in directory it will be redeployed.
Revision Changes Path
1.1 jakarta-avalon-phoenix/lib/container/excalibur-monitor-1.0.jar
<<Binary file>>
1.22 +5 -0 jakarta-avalon-phoenix/src/conf/kernel.xml
Index: kernel.xml
===================================================================
RCS file: /home/cvs/jakarta-avalon-phoenix/src/conf/kernel.xml,v
retrieving revision 1.21
retrieving revision 1.22
diff -u -r1.21 -r1.22
--- kernel.xml 6 Sep 2002 12:44:21 -0000 1.21
+++ kernel.xml 13 Sep 2002 10:26:12 -0000 1.22
@@ -93,5 +93,10 @@
class="org.apache.avalon.excalibur.packagemanager.impl.NoopPackageRepository"
logger="packages"/>
-->
+ <component
+ class="org.apache.avalon.phoenix.components.monitor.DefaultDeploymentMonitor"
+ logger="monitor"/>
+
+
</embeddor>
</phoenix>
1.1 jakarta-avalon-phoenix/src/java/org/apache/avalon/phoenix/components/monitor/DefaultDeploymentMonitor.java
Index: DefaultDeploymentMonitor.java
===================================================================
/*
* Copyright (C) The Apache Software Foundation. All rights reserved.
*
* This software is published under the terms of the Apache Software License
* version 1.1, a copy of which has been included with this distribution in
* the LICENSE.txt file.
*/
package org.apache.avalon.phoenix.components.monitor;
import java.beans.PropertyChangeEvent;
import java.beans.PropertyChangeListener;
import java.io.File;
import java.util.HashSet;
import java.util.Iterator;
import java.util.Set;
import org.apache.avalon.excalibur.i18n.ResourceManager;
import org.apache.avalon.excalibur.i18n.Resources;
import org.apache.avalon.excalibur.io.FileUtil;
import org.apache.avalon.excalibur.monitor.DirectoryResource;
import org.apache.avalon.excalibur.monitor.impl.ActiveMonitor;
import org.apache.avalon.framework.activity.Startable;
import org.apache.avalon.framework.logger.AbstractLogEnabled;
import org.apache.avalon.framework.logger.LogEnabled;
import org.apache.avalon.framework.parameters.ParameterException;
import org.apache.avalon.framework.parameters.Parameterizable;
import org.apache.avalon.framework.parameters.Parameters;
import org.apache.avalon.framework.service.ServiceException;
import org.apache.avalon.framework.service.ServiceManager;
import org.apache.avalon.framework.service.Serviceable;
import org.apache.avalon.phoenix.interfaces.Deployer;
/**
* This class is responsible for monitoring the deployment
* directory and deploying, undelploying or redeploying an
* application as necessary.
*
* @author <a href="mailto:peter at apache.org">Peter Donald</a>
* @version $Revision: 1.1 $ $Date: 2002/09/13 10:26:12 $
*/
public class DefaultDeploymentMonitor
extends AbstractLogEnabled
implements LogEnabled, Parameterizable, Serviceable, Startable, PropertyChangeListener
{
private final static Resources REZ =
ResourceManager.getPackageResources( DefaultDeploymentMonitor.class );
private String m_appsDir;
private ActiveMonitor m_monitor;
private Deployer m_deployer;
/**
* requires parameter "phoenix.apps.dir" to be set to directory
* that the component is to monitor.
*/
public void parameterize( final Parameters parameters )
throws ParameterException
{
m_appsDir = parameters.getParameter( "phoenix.apps.dir" );
}
/**
* Aquire Deployer service for dpeloyment
*/
public void service( final ServiceManager manager )
throws ServiceException
{
m_deployer = (Deployer)manager.lookup( Deployer.ROLE );
}
/**
* Start the monitor.
*/
public void start()
throws Exception
{
final DirectoryResource resource =
new DirectoryResource( m_appsDir );
resource.addPropertyChangeListener( this );
m_monitor = new ActiveMonitor();
m_monitor.setFrequency( 1000L );
m_monitor.addResource( resource );
m_monitor.start();
}
/**
* Stop the monitor.
*/
public void stop()
throws Exception
{
m_monitor.stop();
}
/**
* This method is called when the monitor detects that the contents
* of deployment directory has changed.
*/
public void propertyChange( final PropertyChangeEvent event )
{
final String name = event.getPropertyName();
final Set newValue = (Set)event.getNewValue();
final Set deployments = getDeployments( newValue );
final Iterator iterator = deployments.iterator();
if( name.equals( DirectoryResource.ADDED ) )
{
while( iterator.hasNext() )
{
final File file = (File)iterator.next();
deployApplication( file );
}
}
else if( name.equals( DirectoryResource.REMOVED ) )
{
while( iterator.hasNext() )
{
final File file = (File)iterator.next();
undeployApplication( file );
}
}
else
{
while( iterator.hasNext() )
{
final File file = (File)iterator.next();
redeployApplication( file );
}
}
}
/**
* Deploy application for specified file.
*
* @param file the application archive
*/
private void deployApplication( final File file )
{
final String name =
FileUtil.removeExtension( file.getName() );
try
{
final String message =
REZ.getString( "monitor.deploy.notice",
name,
file );
getLogger().info( message );
m_deployer.deploy( name, file.toURL() );
}
catch( final Exception e )
{
final String message =
REZ.getString( "monitor.no-deploy.error", file, e );
getLogger().warn( message, e );
}
}
/**
* Undeploy application for specified file.
*
* @param file the application archive
*/
private void undeployApplication( final File file )
{
final String name =
FileUtil.removeExtension( file.getName() );
try
{
final String message =
REZ.getString( "monitor.undeploy.notice",
name );
getLogger().info( message );
m_deployer.undeploy( name );
}
catch( final Exception e )
{
final String message =
REZ.getString( "monitor.no-undeploy.error", file, e );
getLogger().warn( message, e );
}
}
/**
* Redeploy application for specified file.
*
* @param file the application archive
*/
private void redeployApplication( final File file )
{
final String name =
FileUtil.removeExtension( file.getName() );
try
{
final String message =
REZ.getString( "monitor.redeploy.notice",
name,
file );
getLogger().info( message );
m_deployer.undeploy( name );
m_deployer.deploy( name, file.toURL() );
}
catch( final Exception e )
{
final String message =
REZ.getString( "monitor.no-redeploy.error", file, e );
getLogger().warn( message, e );
}
}
/**
* Retrieve the set of files that are candidate deployments.
*/
private Set getDeployments( final Set newValue )
{
final Set deployments = new HashSet();
final Iterator iterator = newValue.iterator();
while( iterator.hasNext() )
{
final File file = (File)iterator.next();
if( isDeployment( file ) )
{
deployments.add( file );
}
else
{
final String message =
REZ.getString( "monitor.skipping-file.notice", file );
getLogger().info( message );
}
}
return deployments;
}
/**
* Return true if file represents a phoenix deployment.
*
* @param file the file
* @return
*/
private boolean isDeployment( final File file )
{
return
!file.isDirectory() &&
file.getName().endsWith( ".sar" );
}
}
1.1 jakarta-avalon-phoenix/src/java/org/apache/avalon/phoenix/components/monitor/Resources.properties
Index: Resources.properties
===================================================================
monitor.skipping-file.notice=Change to file "{0}" in deployment directory is being ignored as it is not a candidate deployment.
monitor.no-deploy.error=Failed to deploy file "{0}". (Reason: {1})
monitor.no-undeploy.error=Failed to undeploy file "{0}". (Reason: {1})
monitor.no-redeploy.error=Failed to redeploy file "{0}". (Reason: {1})
monitor.redeploy.notice=Redeploying application {1} as "{0}".
monitor.deploy.notice=Deploying application {1} as "{0}".
monitor.undeploy.notice=Undeploying application "{0}".
--
To unsubscribe, e-mail: <ma...@jakarta.apache.org>
For additional commands, e-mail: <ma...@jakarta.apache.org>
Re: cvs commit: jakarta-avalon-phoenix/src/java/org/apache/avalon/phoenix/components/monitor DefaultDeploymentMonitor.java Resources.properties
Posted by Peter Donald <pe...@apache.org>.
Hi,
Heres a change I just made ...
On Fri, 13 Sep 2002 20:26, donaldp@apache.org wrote:
> Add a monitor for the deployment directory. This component will monitor
> the dpeloyment directory and
>
> If .sar file is added to directory it will be deployed.
> If .sar file is removed from directory it will be undeployed.
> If .sar file is modified in directory it will be redeployed.
Essentially we now monitor a directory and will try to deploy, undeploy or
redeploy when the contents of directory change.
--
Cheers,
Peter Donald
A right is not what someone gives you; it's what no one can take from you.
-- Ramsey Clark
--
To unsubscribe, e-mail: <ma...@jakarta.apache.org>
For additional commands, e-mail: <ma...@jakarta.apache.org>