public void scheduleDatabaseTasks()
throws TaskExecutionException;
+ public void startup()
+ throws ArchivaException;
}
import org.codehaus.plexus.registry.RegistryListener;
import org.codehaus.plexus.scheduler.CronExpressionValidator;
import org.codehaus.plexus.scheduler.Scheduler;
+import org.codehaus.plexus.taskqueue.Task;
import org.codehaus.plexus.taskqueue.TaskQueue;
import org.codehaus.plexus.taskqueue.TaskQueueException;
import org.codehaus.plexus.taskqueue.execution.TaskExecutionException;
import org.quartz.SchedulerException;
import java.text.ParseException;
-import java.util.Iterator;
import java.util.List;
/**
public static final String CRON_HOURLY = "0 0 * * * ?";
+ public void startup()
+ throws ArchivaException
+ {
+ try
+ {
+ start();
+ }
+ catch ( StartingException e )
+ {
+ throw new ArchivaException( e.getMessage(), e );
+ }
+ }
+
public void start()
throws StartingException
{
try
{
- List repositories = archivaConfiguration.getConfiguration().getManagedRepositories();
+ List<ManagedRepositoryConfiguration> repositories = archivaConfiguration.getConfiguration()
+ .getManagedRepositories();
- for ( Iterator i = repositories.iterator(); i.hasNext(); )
+ for ( ManagedRepositoryConfiguration repoConfig : repositories )
{
- ManagedRepositoryConfiguration repoConfig = (ManagedRepositoryConfiguration) i.next();
-
if ( repoConfig.isScanned() )
{
scheduleRepositoryJobs( repoConfig );
// currently we have to reschedule all repo jobs because we don't know where the changed one came from
if ( "refreshCronExpression".equals( propertyName ) )
{
- List repositories = archivaConfiguration.getConfiguration().getManagedRepositories();
+ List<ManagedRepositoryConfiguration> repositories = archivaConfiguration.getConfiguration()
+ .getManagedRepositories();
- for ( Iterator i = repositories.iterator(); i.hasNext(); )
+ for ( ManagedRepositoryConfiguration repoConfig : repositories )
{
- ManagedRepositoryConfiguration repoConfig = (ManagedRepositoryConfiguration) i.next();
-
if ( repoConfig.getRefreshCronExpression() != null )
{
try
public boolean isProcessingAnyRepositoryTask()
throws ArchivaException
{
- List queue = null;
+ List<? extends Task> queue = null;
try
{
public boolean isProcessingRepositoryTask( String repositoryId )
throws ArchivaException
{
- List queue = null;
+ List<? extends Task> queue = null;
try
{
public boolean isProcessingDatabaseTask()
throws ArchivaException
{
- List queue = null;
+ List<? extends Task> queue = null;
try
{
--- /dev/null
+package org.apache.maven.archiva.web.startup;
+
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied. See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+
+import org.apache.maven.archiva.common.ArchivaException;
+import org.apache.maven.archiva.scheduled.ArchivaTaskScheduler;
+import org.codehaus.plexus.logging.AbstractLogEnabled;
+import org.codehaus.plexus.personality.plexus.lifecycle.phase.Initializable;
+import org.codehaus.plexus.personality.plexus.lifecycle.phase.InitializationException;
+
+/**
+ * ArchivaStartup - the startup of all archiva features in a deterministic order.
+ *
+ * @author <a href="mailto:joakim@erdfelt.com">Joakim Erdfelt</a>
+ * @version $Id$
+ *
+ * @plexus.component
+ * role="org.apache.maven.archiva.web.startup.ArchivaStartup"
+ * role-hint="default"
+ */
+public class ArchivaStartup
+ extends AbstractLogEnabled
+ implements Initializable
+{
+ /**
+ * @plexus.requirement role-hint="default"
+ */
+ private ConfigurationSynchronization configSync;
+
+ /**
+ * @plexus.requirement role-hint="default"
+ */
+ private ResolverFactoryInit resolverFactory;
+
+ /**
+ * @plexus.requirement role-hint="default"
+ */
+ private ArchivaTaskScheduler taskScheduler;
+
+ public void initialize()
+ throws InitializationException
+ {
+ Banner.display( getLogger(), ArchivaVersion.determineVersion( this.getClass().getClassLoader() ) );
+
+ try
+ {
+ configSync.startup();
+ resolverFactory.startup();
+ taskScheduler.startup();
+ }
+ catch ( ArchivaException e )
+ {
+ throw new InitializationException( "Unable to properly startup archiva: " + e.getMessage(), e );
+ }
+ }
+
+}
import org.apache.commons.lang.StringUtils;
import org.codehaus.plexus.logging.AbstractLogEnabled;
import org.codehaus.plexus.logging.Logger;
-import org.codehaus.plexus.personality.plexus.lifecycle.phase.Initializable;
import org.codehaus.plexus.personality.plexus.lifecycle.phase.InitializationException;
import java.util.regex.Matcher;
*/
public class Banner
extends AbstractLogEnabled
- implements Initializable
{
public static String encode( String raw )
{
* under the License.
*/
+import org.apache.maven.archiva.common.ArchivaException;
import org.apache.maven.archiva.common.utils.PathUtil;
import org.apache.maven.archiva.configuration.ArchivaConfiguration;
import org.apache.maven.archiva.configuration.ConfigurationNames;
import org.apache.maven.archiva.model.ArchivaRepository;
import org.apache.maven.archiva.repository.ArchivaConfigurationAdaptor;
import org.codehaus.plexus.logging.AbstractLogEnabled;
-import org.codehaus.plexus.personality.plexus.lifecycle.phase.Initializable;
-import org.codehaus.plexus.personality.plexus.lifecycle.phase.InitializationException;
import org.codehaus.plexus.redback.role.RoleManager;
import org.codehaus.plexus.redback.role.RoleManagerException;
import org.codehaus.plexus.registry.Registry;
import org.codehaus.plexus.registry.RegistryListener;
-import java.util.Iterator;
import java.util.List;
/**
*/
public class ConfigurationSynchronization
extends AbstractLogEnabled
- implements RegistryListener, Initializable
+ implements RegistryListener
{
/**
* @plexus.requirement role-hint="jdo"
/* do nothing */
}
- private void synchConfiguration( List repos )
+ private void synchConfiguration( List<ManagedRepositoryConfiguration> repos )
{
- Iterator it = repos.iterator();
- while ( it.hasNext() )
+ for ( ManagedRepositoryConfiguration repoConfig : repos )
{
- ManagedRepositoryConfiguration repoConfig = (ManagedRepositoryConfiguration) it.next();
try
{
try
}
}
- public void initialize()
- throws InitializationException
+ public void startup()
+ throws ArchivaException
{
synchConfiguration( archivaConfiguration.getConfiguration().getManagedRepositories() );
archivaConfiguration.addChangeListener( this );
* under the License.
*/
+import org.apache.maven.archiva.common.ArchivaException;
import org.apache.maven.archiva.database.project.ProjectModelToDatabaseListener;
import org.apache.maven.archiva.repository.project.ProjectModelResolver;
import org.apache.maven.archiva.repository.project.ProjectModelResolverFactory;
import org.codehaus.plexus.logging.AbstractLogEnabled;
-import org.codehaus.plexus.personality.plexus.lifecycle.phase.Initializable;
-import org.codehaus.plexus.personality.plexus.lifecycle.phase.InitializationException;
/**
* ResolverFactoryInit - Initialize the Resolver Factory, and hook it up to
*/
public class ResolverFactoryInit
extends AbstractLogEnabled
- implements Initializable
{
/**
* @plexus.requirement role-hint="database"
*/
private ProjectModelResolver databaseResolver;
-
+
/**
* @plexus.requirement
* role="org.apache.maven.archiva.repository.project.resolvers.ProjectModelResolutionListener"
* @plexus.requirement
*/
private ProjectModelResolverFactory resolverFactory;
-
- public void initialize()
- throws InitializationException
+
+ public void startup()
+ throws ArchivaException
{
if ( !resolverFactory.getCurrentResolverStack().hasResolver( databaseResolver ) )
{
<plexus>
<load-on-start>
<component>
- <role>org.apache.maven.archiva.web.startup.Banner</role>
- <role-hint>default</role-hint>
- </component>
- <component>
- <role>org.apache.maven.archiva.web.startup.ConfigurationSynchronization</role>
- <role-hint>default</role-hint>
- </component>
- <component>
- <role>org.apache.maven.archiva.web.startup.ResolverFactoryInit</role>
- <role-hint>default</role-hint>
- </component>
- <component>
- <role>org.apache.maven.archiva.web.startup.Banner</role>
- <role-hint>default</role-hint>
- </component>
- <component>
- <role>org.apache.maven.archiva.scheduled.ArchivaTaskScheduler</role>
+ <role>org.apache.maven.archiva.web.startup.ArchivaStartup</role>
<role-hint>default</role-hint>
</component>
<component>