Clover Coverage Report - Implementation 2.0.0-SNAPSHOT
Coverage timestamp: Wed Dec 31 1969 19:00:00 EST
Overview   Package   File
    FRAMES   NO FRAMES     
../../../../../img/srcFileCovDistChart0.png 0% of files have more coverage
18   68   7   9
10   44   0.39   2
2     3.5  
1    
 
  XmlPipelineLifeCycle       Line # 30 18 0% 7 30 0% 0.0
 
No Tests
 
1    /*
2    * Copyright 2006-2011 The Kuali Foundation
3    *
4    * Licensed under the Educational Community License, Version 2.0 (the "License");
5    * you may not use this file except in compliance with the License.
6    * You may obtain a copy of the License at
7    *
8    * http://www.opensource.org/licenses/ecl2.php
9    *
10    * Unless required by applicable law or agreed to in writing, software
11    * distributed under the License is distributed on an "AS IS" BASIS,
12    * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
13    * See the License for the specific language governing permissions and
14    * limitations under the License.
15    */
16   
17    package org.kuali.rice.kew.lifecycle;
18   
19    import org.kuali.rice.core.api.config.property.ConfigContext;
20    import org.kuali.rice.core.api.lifecycle.BaseLifecycle;
21    import org.kuali.rice.core.api.lifecycle.BaseLifecycle;
22    import org.kuali.rice.kew.batch.XmlPollerService;
23    import org.kuali.rice.kew.service.KEWServiceLocator;
24   
25    import java.util.concurrent.Executors;
26    import java.util.concurrent.ScheduledExecutorService;
27    import java.util.concurrent.ScheduledFuture;
28    import java.util.concurrent.TimeUnit;
29   
 
30    public class XmlPipelineLifeCycle extends BaseLifecycle {
31   
32    protected final org.apache.log4j.Logger LOG = org.apache.log4j.Logger.getLogger(XmlPipelineLifeCycle.class);
33   
34    private ScheduledExecutorService scheduledExecutor;
35    private ScheduledFuture future;
36   
 
37  0 toggle public void start() throws Exception {
38  0 LOG.info("Configuring XML ingestion pipeline...");
39  0 scheduledExecutor = Executors.newScheduledThreadPool(1);
40  0 final XmlPollerService xmlPoller = KEWServiceLocator.getXmlPollerService();
41  0 LOG.info("Starting XML data loader. Polling at " + xmlPoller.getPollIntervalSecs() + "-second intervals");
42  0 if (!ConfigContext.getCurrentContextConfig().getDevMode()) {
43  0 future = scheduledExecutor.scheduleWithFixedDelay(xmlPoller, xmlPoller.getInitialDelaySecs(), xmlPoller.getPollIntervalSecs(), TimeUnit.SECONDS);
44  0 super.start();
45    }
46    }
47   
 
48  0 toggle public void stop() throws Exception {
49  0 if (isStarted()) {
50  0 LOG.warn("Shutting down XML file polling timer");
51  0 try {
52  0 if (future != null) {
53  0 if (!future.cancel(false)) {
54  0 LOG.warn("Failed to cancel the XML Poller service.");
55    }
56  0 future = null;
57    }
58  0 if (scheduledExecutor != null) {
59  0 scheduledExecutor.shutdownNow();
60  0 scheduledExecutor = null;
61    }
62    } finally {
63  0 super.stop();
64    }
65    }
66    }
67   
68    }
 
CloverReport generated by Clover Code Coverage v3.0.2
Wed Apr 13 2011 04:19:36 EDT.		   Clover: Open Source License registered to University of Arizona.