From 091ebb7aeaf7da455970e75ee520748472a99a1b Mon Sep 17 00:00:00 2001
From: Brett Porter <brett@apache.org>
Date: Thu, 23 Dec 2010 03:15:17 +0000
Subject: [PATCH] avoid exception if the scheduler never started

git-svn-id: https://svn.apache.org/repos/asf/archiva/trunk@1052162 13f79535-47bb-0310-9956-ffa450edef68
---
 .../archiva/web/startup/ArchivaStartup.java   | 64 +++++++++----------
 1 file changed, 29 insertions(+), 35 deletions(-)

diff --git a/archiva-modules/archiva-web/archiva-webapp/src/main/java/org/apache/maven/archiva/web/startup/ArchivaStartup.java b/archiva-modules/archiva-web/archiva-webapp/src/main/java/org/apache/maven/archiva/web/startup/ArchivaStartup.java
index b9cebd807..6c57143f7 100644
--- a/archiva-modules/archiva-web/archiva-webapp/src/main/java/org/apache/maven/archiva/web/startup/ArchivaStartup.java
+++ b/archiva-modules/archiva-web/archiva-webapp/src/main/java/org/apache/maven/archiva/web/startup/ArchivaStartup.java
@@ -19,11 +19,7 @@ package org.apache.maven.archiva.web.startup;
  * under the License.
  */
 
-import java.lang.reflect.Field;
-
-import javax.servlet.ServletContextEvent;
-import javax.servlet.ServletContextListener;
-
+import edu.emory.mathcs.backport.java.util.concurrent.ExecutorService;
 import org.apache.archiva.scheduler.ArchivaTaskScheduler;
 import org.apache.archiva.scheduler.repository.RepositoryArchivaTaskScheduler;
 import org.apache.maven.archiva.common.ArchivaException;
@@ -38,7 +34,9 @@ import org.springframework.context.support.ClassPathXmlApplicationContext;
 import org.springframework.web.context.WebApplicationContext;
 import org.springframework.web.context.support.WebApplicationContextUtils;
 
-import edu.emory.mathcs.backport.java.util.concurrent.ExecutorService;
+import java.lang.reflect.Field;
+import javax.servlet.ServletContextEvent;
+import javax.servlet.ServletContextListener;
 
 /**
  * ArchivaStartup - the startup of all archiva features in a deterministic order.
@@ -55,27 +53,23 @@ public class ArchivaStartup
     private ThreadedTaskQueueExecutor tqeIndexing;
 
     private RepositoryArchivaTaskScheduler repositoryTaskScheduler;
-    
+
     public void contextInitialized( ServletContextEvent contextEvent )
     {
-        WebApplicationContext wac =
-            WebApplicationContextUtils.getRequiredWebApplicationContext( contextEvent.getServletContext() );
+        WebApplicationContext wac = WebApplicationContextUtils.getRequiredWebApplicationContext(
+            contextEvent.getServletContext() );
 
-        SecuritySynchronization securitySync =
-            (SecuritySynchronization) wac.getBean( PlexusToSpringUtils.buildSpringId( SecuritySynchronization.class ) );
+        SecuritySynchronization securitySync = (SecuritySynchronization) wac.getBean( PlexusToSpringUtils.buildSpringId(
+            SecuritySynchronization.class ) );
 
-        repositoryTaskScheduler =
-            (RepositoryArchivaTaskScheduler) wac.getBean( PlexusToSpringUtils.buildSpringId(
-                                                                                             ArchivaTaskScheduler.class,
-                                                                                             "repository" ) );
+        repositoryTaskScheduler = (RepositoryArchivaTaskScheduler) wac.getBean( PlexusToSpringUtils.buildSpringId(
+            ArchivaTaskScheduler.class, "repository" ) );
 
-        tqeRepoScanning =
-            (ThreadedTaskQueueExecutor) wac.getBean( PlexusToSpringUtils.buildSpringId( TaskQueueExecutor.class,
-                                                                                        "repository-scanning" ) );
+        tqeRepoScanning = (ThreadedTaskQueueExecutor) wac.getBean( PlexusToSpringUtils.buildSpringId(
+            TaskQueueExecutor.class, "repository-scanning" ) );
 
-        tqeIndexing =
-            (ThreadedTaskQueueExecutor) wac.getBean( PlexusToSpringUtils.buildSpringId( TaskQueueExecutor.class,
-                                                                                        "indexing" ) );
+        tqeIndexing = (ThreadedTaskQueueExecutor) wac.getBean( PlexusToSpringUtils.buildSpringId(
+            TaskQueueExecutor.class, "indexing" ) );
 
         try
         {
@@ -91,8 +85,8 @@ public class ArchivaStartup
 
     public void contextDestroyed( ServletContextEvent contextEvent )
     {
-        WebApplicationContext applicationContext =
-            WebApplicationContextUtils.getRequiredWebApplicationContext( contextEvent.getServletContext() );
+        WebApplicationContext applicationContext = WebApplicationContextUtils.getRequiredWebApplicationContext(
+            contextEvent.getServletContext() );
         if ( applicationContext != null && applicationContext instanceof ClassPathXmlApplicationContext )
         {
             ( (ClassPathXmlApplicationContext) applicationContext ).close();
@@ -116,20 +110,20 @@ public class ArchivaStartup
                 {
                     e.printStackTrace();
                 }
-            }
 
-            try
-            {
-                // shutdown the scheduler, otherwise Quartz scheduler and Threads still exists
-                Field schedulerField = repositoryTaskScheduler.getClass().getDeclaredField( "scheduler" );
-                schedulerField.setAccessible( true );
+                try
+                {
+                    // shutdown the scheduler, otherwise Quartz scheduler and Threads still exists
+                    Field schedulerField = repositoryTaskScheduler.getClass().getDeclaredField( "scheduler" );
+                    schedulerField.setAccessible( true );
 
-                DefaultScheduler scheduler = (DefaultScheduler) schedulerField.get( repositoryTaskScheduler );
-                scheduler.stop();
-            }
-            catch ( Exception e )
-            {   
-                e.printStackTrace();
+                    DefaultScheduler scheduler = (DefaultScheduler) schedulerField.get( repositoryTaskScheduler );
+                    scheduler.stop();
+                }
+                catch ( Exception e )
+                {
+                    e.printStackTrace();
+                }
             }
 
             // close the application context
-- 
2.39.5