cvs commit: avalon/merlin/kernel/impl/src/java/org/apache/avalon/merlin/kernel/impl DefaultLoader.java

[mc...@apache.org]

mcconnell    2003/10/12 10:16:30

  Added:       merlin/kernel/impl/src/java/org/apache/avalon/merlin/kernel/impl
                        DefaultLoader.java
  Log:
  Just playing around.
  
  Revision  Changes    Path
  1.1                  avalon/merlin/kernel/impl/src/java/org/apache/avalon/merlin/kernel/impl/DefaultLoader.java
  
  Index: DefaultLoader.java
  ===================================================================
  
  
  package org.apache.avalon.merlin.kernel.impl;
  
  import java.io.File;
  import java.io.FileNotFoundException;
  import java.io.IOException;
  import java.io.FileInputStream;
  import java.io.IOException;
  import java.io.InputStream;
  import java.util.Map;
  import java.util.Locale;
  import java.net.MalformedURLException;
  import java.net.URL;
  
  import org.apache.avalon.activation.appliance.Appliance;
  import org.apache.avalon.activation.appliance.Block;
  import org.apache.avalon.composition.util.ExceptionHelper;
  import org.apache.avalon.composition.model.ContainmentModel;
  import org.apache.avalon.framework.logger.Logger;
  import org.apache.avalon.framework.configuration.Configuration;
  import org.apache.avalon.framework.configuration.ConfigurationException;
  import org.apache.avalon.framework.configuration.DefaultConfigurationBuilder;
  import org.apache.avalon.framework.activity.Startable;
  import org.apache.avalon.merlin.kernel.Kernel;
  import org.apache.avalon.merlin.kernel.KernelContext;
  import org.apache.avalon.merlin.kernel.KernelException;
  import org.apache.avalon.excalibur.i18n.ResourceManager;
  import org.apache.avalon.excalibur.i18n.Resources;
  import org.apache.avalon.repository.BlockManifest;
  import org.apache.avalon.repository.Repository;
  import org.xml.sax.SAXException;
  
  /**
   * The DefaultLoader loads a Merlin Kernel based on a supplied argument map.
   */
  public class DefaultLoader
  {
      //--------------------------------------------------------------------------
      // static
      //--------------------------------------------------------------------------
  
      private static Resources REZ =
          ResourceManager.getPackageResources( DefaultLoader.class );
  
      //--------------------------------------------------------------------------
      // state
      //--------------------------------------------------------------------------
  
      private DefaultKernel m_kernel;
  
      //--------------------------------------------------------------------------
      // constructor
      //--------------------------------------------------------------------------
  
     /**
      * Creation of a new loader.  The supplied repository is 
      * used as the default deployment repository.  Depending on command
      * line arguments, the repository established for runtime deployment
      * may be changed.
      *
      * @param system the bootstrap repository from which merlin 
      *   system jar files have been resolved
      * @param args the set of command line arguments 
      */
      public DefaultLoader( final Repository repository, Map map ) 
        throws Exception
      {
          File repo = (File) map.get( "merlin.repository.dir" );
          File library = (File) map.get( "merlin.library.dir" );
          File base = (File) map.get( "merlin.base.dir" );
          URL kernel = (URL) map.get( "merlin.kernel.url" );
          URL targets = (URL) map.get( "merlin.targets.url" );
          boolean info = getBooleanValue( (Boolean) map.get( "merlin.policy.info" ), false );
          boolean debug = getBooleanValue( (Boolean) map.get( "merlin.policy.debug" ), false );
  
          try
          {
              DefaultKernelContext context = 
                new DefaultKernelContext( 
                  repository, repo, library, base, kernel, new URL[0], 
                  targets, true, info, debug );
              m_kernel = new DefaultKernel( context );
          }
          catch( Throwable e )
          {
              final String message =
                "Internal error while attempting to establish the kernel.";
              final String error = ExceptionHelper.packException( message, e, true );
              throw new KernelException( error, e );
          }
      }
  
     /**
      * Return the kernel.
      * @return the kernel
      */
      public Kernel getKernel()
      {
          return m_kernel;
      }
  
     /**
      * Return the root containment model.
      * @return the containment model
      */
      public ContainmentModel getContainmentModel()
      {
          return m_kernel.getContainmentModel();
      }
  
     /**
      * Return the block matching the supplied model.
      * @return the containment block
      */
      public Block getBlock( ContainmentModel model ) throws KernelException
      {
          return m_kernel.getBlock( model );
      }
  
     /**
      * Return the root block.
      * @return the containment block
      */
      public Block getRootBlock()
      {
          return m_kernel.getRootBlock();
      }
  
      public void startup() throws Exception
      {
          m_kernel.startup();
      }
  
     /**
      * Resolve a service relative to the root container. 
      *
      * @param path the absolute or relative path to an appliance
      * @return the resolved object
      * @exception Exception if a resolution error occurs
      */
      public Object resolve( String path ) throws Exception
      {
          if( path == null ) throw new NullPointerException( "path" );
  
          try
          {
              Appliance appliance = m_kernel.getRootBlock().resolveAppliance( path );
              if( appliance == null )
              {
                  final String problem = 
                    "Unknown appliance: " + path;
                  throw new IllegalArgumentException( problem );
              }
              return appliance.resolve( this );
          }
          catch( Throwable e )
          {
              final String error = 
                "Service resolution error from path: " + path;
              final String msg = ExceptionHelper.packException( error, e, false );
              throw new KernelException( msg, e );
          }
      }
  
      public void shutdown()
      {
          m_kernel.shutdown();
      }
  
      private boolean getBooleanValue( Boolean value, boolean fallback )
      {
          if( value == null ) return fallback;
          return value.booleanValue();
      }
  }
  
  
  

---------------------------------------------------------------------
To unsubscribe, e-mail: cvs-unsubscribe@avalon.apache.org
For additional commands, e-mail: cvs-help@avalon.apache.org