1 17 18 package org.apache.geronimo.timer; 19 20 import org.apache.commons.logging.Log; 21 import org.apache.commons.logging.LogFactory; 22 23 26 public class NontransactionalExecutorTask implements ExecutorTask { 27 28 private static final Log log = LogFactory.getLog(NontransactionalExecutorTask.class); 29 30 private final Runnable userTask; 31 private final WorkInfo workInfo; 32 private final ThreadPooledTimer threadPooledTimer; 33 34 public NontransactionalExecutorTask(Runnable userTask, WorkInfo workInfo, ThreadPooledTimer threadPooledTimer) { 35 this.userTask = userTask; 36 this.workInfo = workInfo; 37 this.threadPooledTimer = threadPooledTimer; 38 } 39 40 public void run() { 41 try { 42 userTask.run(); 43 } catch (Exception e) { 44 log.warn("Exception running task", e); 45 } 46 try { 47 threadPooledTimer.workPerformed(workInfo); 48 } catch (PersistenceException e) { 49 log.warn("Exception completing task", e); 50 } 51 if (workInfo.isOneTime()) { 52 threadPooledTimer.removeWorkInfo(workInfo); 53 } 54 } 55 } 56 | Popular Tags |