Spring(version 2.5)+ Quartz - SchedulerFactoryBean - waitForJobsToCompleteOnShutdown

[Jacob Tom]

Hi,

As per the documentation of property "waitForJobsToCompleteOnShutdown" within "org.springframework.scheduling.quartz.SchedulerFactoryBean", Spring should wait for running jobs to complete before shutdown.

I have configured the scheduler in spring configuration xml as shown below -

<bean id="evaluatorPollerScheduler"
		class="org.springframework.scheduling.quartz.SchedulerFactoryBean">
		<property name="jobFactory">
			<bean class="org.springframework.scheduling.quartz.SpringBeanJobFactory" />
		</property>
		<property name="quartzProperties">
			<props>
				<prop key="org.quartz.threadPool.class">org.quartz.simpl.SimpleThreadPool</prop>
				<prop key="org.quartz.threadPool.threadCount">${scheduler.evaluator.thread.count}</prop>
			</props>
		</property>
		<property name="waitForJobsToCompleteOnShutdown" value="true" />
	</bean>

I also have configured correponding trigger and job. Then I am scheduling the job using the scheduler.

This Spring module is deployed on weblogic 8.1.

When a 'shutdown' is issued from weblogic, it appears that weblogic does not wait for the spring job to complete before shutdown even though 'waitForJobsToCompleteOnShutdown' is set to TRUE.

Could you please advice what could be wrong?

Please let me know if you need any more details.

Regards,
Jacob

[Bill Gorder]

Is Weblogic issuing a graceful shutdown to the Spring context? It is the context closing event that handles this, it has nothing to do with Weblogic. You can test this by running it in a standalone application and calling close on the context. If Weblogic won't wait there is nothing you can do.

[Jacob Tom]

Thanks Bill for reply.

Weblogic is issuing graceful shutdown. Please find below class that extends "ContextLoaderListener". Is there anything I need to do more in the "contextDestroyed" method to ensure that weblogic waits till all my currently running jobs are finished before shutting down?

package com.test.proview.notificationengine.servlet;

import javax.servlet.ServletContextEvent;

import org.apache.log4j.Logger;
import org.springframework.web.context.ContextLoader;
import org.springframework.web.context.ContextLoaderListener;
import org.springframework.web.context.WebApplicationContext;

import com.test.proview.notificationengine.scheduler.NotificationScheduleManager;
import com.test.proview.notificationengine.util.NotificationEngineConstants;

/**
 * Listener which initializes Spring context. Also triggers the quartz job scheduling.
 * 
 *  
 */
public class SpringInitListener extends ContextLoaderListener
{
    private static final Logger logger     =
                                               Logger
                                                   .getLogger(NotificationEngineConstants.NOTIFICATIONENGINE_LOG_APPENDER);

    private static final String CLASS_NAME = SpringInitListener.class.getName();

    private ContextLoader       contextLoader;

    /*
     * (non-Javadoc)
     * 
     * @see org.springframework.web.context.ContextLoaderListener#contextInitialized(javax.servlet.ServletContextEvent)
     */
    public void contextInitialized(ServletContextEvent event)
    {
        final String METHOD_NAME = " | contextInitialized | ";
        logger.info(CLASS_NAME + METHOD_NAME
            + NotificationEngineConstants.STARTS);

        this.contextLoader = createContextLoader();
        WebApplicationContext context =
            this.contextLoader.initWebApplicationContext(event
                .getServletContext());

        logger.debug(CLASS_NAME + METHOD_NAME
            + "contextInitialized successfully");

        NotificationScheduleManager manager =
            (NotificationScheduleManager) context
                .getBean(NotificationEngineConstants.SCHEDULER_MANAGER_BEAN);
        manager.scheduleNewJob(null,
            NotificationEngineConstants.EVALUATOR_POLLER_NAME, null,
            NotificationEngineConstants.DIGEST_POLLER_NAME, null,
            NotificationEngineConstants.PENDING_POLLER_NAME, null,
            NotificationEngineConstants.REGULAR_POLLER_NAME);

        logger.debug(CLASS_NAME + METHOD_NAME
            + "scheduleNewJob executed succesfully");

        logger
            .info(CLASS_NAME + METHOD_NAME + NotificationEngineConstants.ENDS);

    }

    /*
     * (non-Javadoc)
     * 
     * @see org.springframework.web.context.ContextLoaderListener#createContextLoader()
     */
    protected ContextLoader createContextLoader()
    {
        return new ContextLoader();
    }

    /*
     * (non-Javadoc)
     * 
     * @see org.springframework.web.context.ContextLoaderListener#getContextLoader()
     */
    public ContextLoader getContextLoader()
    {
        return this.contextLoader;
    }

    /*
     * (non-Javadoc)
     * 
     * @see org.springframework.web.context.ContextLoaderListener#contextDestroyed(javax.servlet.ServletContextEvent)
     */
    public void contextDestroyed(ServletContextEvent event)
    {
               
        if (this.contextLoader != null){
            
            this.contextLoader.closeWebApplicationContext(event
                .getServletContext());
        }
    }
}

Regards,
Jacob