xfireblockdeployerapplicationlistener.java

Xfire文件 用于开发web service 的一个开源工具 很好用的

package org.codehaus.xfire.loom;

import java.util.HashMap;
import java.util.Iterator;
import java.util.Map;

import org.apache.avalon.framework.configuration.Configurable;
import org.apache.avalon.framework.configuration.Configuration;
import org.apache.avalon.framework.configuration.ConfigurationException;
import org.apache.avalon.framework.logger.AbstractLogEnabled;
import org.apache.avalon.phoenix.ApplicationEvent;
import org.apache.avalon.phoenix.ApplicationListener;
import org.apache.avalon.phoenix.BlockEvent;
import org.apache.avalon.phoenix.metainfo.BlockInfo;
import org.apache.avalon.phoenix.metainfo.ServiceDescriptor;

/**
 * @author <a href="mailto:[e-mail]">peter royal</a>
 */
public class XFireBlockDeployerApplicationListener extends AbstractLogEnabled
    implements ApplicationListener, Configurable
{
    private ServiceDeployer m_deployer;
    private Map m_services;

    public void configure( final Configuration configuration ) throws ConfigurationException
    {
        final Configuration[] kids = configuration.getChildren( "service" );

        m_services = new HashMap( kids.length );

        for( int i = 0; i < kids.length; i++ )
        {
            m_services.put( kids[i].getValue(), null );
        }
    }

    public void applicationFailure( final Exception e )
    {
    }

    public void applicationStarted()
    {
        if( null == m_deployer )
        {
            throw new IllegalStateException( "Must provide a " + ServiceDeployer.class.getName() );
        }

        final Iterator i = m_services.entrySet().iterator();

        while( i.hasNext() )
        {
            final Map.Entry entry = (Map.Entry)i.next();

            if( null == entry.getValue() )
            {
                throw new IllegalStateException( "Unable to deploy configured service: " + entry.getKey() );
            }

            if( getLogger().isDebugEnabled() ) getLogger().debug( "Deploying '" + entry.getKey() + "'" );

            try
            {
                m_deployer.deploy( (String)entry.getKey(), entry.getValue() );
            }
            catch( Exception e )
            {
                throw new RuntimeException( "Unable to deploy '" + entry.getKey() + "'", e );
            }
        }
    }

    public void applicationStarting( final ApplicationEvent event ) throws Exception
    {
    }

    public void applicationStopped()
    {
    }

    public void applicationStopping()
    {
        final Iterator i = m_services.keySet().iterator();

        while( i.hasNext() )
        {
            final String service = (String)i.next();

            if( getLogger().isDebugEnabled() ) getLogger().debug( "Undeploying '" + service + "'" );

            m_deployer.undeploy( service );
        }
    }

    public void blockAdded( final BlockEvent event )
    {
        if( isServiceDeployer( event.getBlockInfo() ) )
        {
            if( null == m_deployer )
            {
                if( getLogger().isDebugEnabled() )
                    getLogger().debug( "Using '" + event.getName() + "' as ServiceDeployer" );

                m_deployer = (ServiceDeployer)event.getObject();
            }
            else
            {
                throw new RuntimeException( "Duplicate ServiceDeployer found: " + event.getName() );
            }
        }
        else if( m_services.containsKey( event.getName() ) )
        {
            if( getLogger().isDebugEnabled() )
                getLogger().debug( "Marking '" + event.getName() + "' for XFire deploment" );

            m_services.put( event.getName(), event.getObject() );
        }
    }

    private boolean isServiceDeployer( final BlockInfo blockInfo )
    {
        final ServiceDescriptor[] services = blockInfo.getServices();

        for( int i = 0; i < services.length; i++ )
        {
            if( ServiceDeployer.class.getName().equals( services[i].getName() ) )
            {
                return true;
            }
        }

        return false;
    }

    public void blockRemoved( final BlockEvent event )
    {
    }
}