Author: rgoers Date: Wed Jan 19 11:58:55 2005 New Revision: 125646 URL: http://svn.apache.org/viewcvs?view=rev&rev=125646 Log: executor attribute was never being set. Fix NPE.
Modified: cocoon/trunk/src/blocks/cron/java/org/apache/cocoon/components/cron/QuartzJobScheduler.java Modified: cocoon/trunk/src/blocks/cron/java/org/apache/cocoon/components/cron/QuartzJobScheduler.java Url: http://svn.apache.org/viewcvs/cocoon/trunk/src/blocks/cron/java/org/apache/cocoon/components/cron/QuartzJobScheduler.java?view=diff&rev=125646&p1=cocoon/trunk/src/blocks/cron/java/org/apache/cocoon/components/cron/QuartzJobScheduler.java&r1=125645&p2=cocoon/trunk/src/blocks/cron/java/org/apache/cocoon/components/cron/QuartzJobScheduler.java&r2=125646 ============================================================================== --- cocoon/trunk/src/blocks/cron/java/org/apache/cocoon/components/cron/QuartzJobScheduler.java (original) +++ cocoon/trunk/src/blocks/cron/java/org/apache/cocoon/components/cron/QuartzJobScheduler.java Wed Jan 19 11:58:55 2005 @@ -572,7 +572,8 @@ jobDataMap.put(DATA_MAP_LOGGER, getLogger()); jobDataMap.put(DATA_MAP_CONTEXT, this.context); jobDataMap.put(DATA_MAP_MANAGER, this.manager); - jobDataMap.put(DATA_MAP_RUN_CONCURRENT, concurent? Boolean.TRUE: Boolean.FALSE); + jobDataMap.put(DATA_MAP_RUN_CONCURRENT, + concurent? Boolean.TRUE.booleanValue(): Boolean.FALSE.booleanValue()); if (null != params) { jobDataMap.put(DATA_MAP_PARAMETERS, params); } @@ -606,15 +607,16 @@ m_shutdownGraceful = poolConfig.getChild("shutdown-graceful").getValueAsBoolean(true); final int shutdownWaitTimeMs = poolConfig.getChild("shutdown-wait-time-ms").getValueAsInteger(-1); final RunnableManager runnableManager = (RunnableManager)this.manager.lookup(RunnableManager.ROLE); - final QuartzThreadPool pool = new QuartzThreadPool(runnableManager.createPool(queueSize, - maxPoolSize, - minPoolSize, - Thread.NORM_PRIORITY, - false, // no daemon - keepAliveTimeMs, - blockPolicy, - m_shutdownGraceful, - shutdownWaitTimeMs)); + this.executor = runnableManager.createPool(queueSize, + maxPoolSize, + minPoolSize, + Thread.NORM_PRIORITY, + false, // no daemon + keepAliveTimeMs, + blockPolicy, + m_shutdownGraceful, + shutdownWaitTimeMs); + final QuartzThreadPool pool = new QuartzThreadPool(this.executor); return pool; }
