diff --git a/modules/quartz/src/main/java/org/jpos/q2/QuartzAdaptor.java b/modules/quartz/src/main/java/org/jpos/q2/QuartzAdaptor.java index af5a18039d..15d97128d9 100644 --- a/modules/quartz/src/main/java/org/jpos/q2/QuartzAdaptor.java +++ b/modules/quartz/src/main/java/org/jpos/q2/QuartzAdaptor.java @@ -119,5 +119,9 @@ public String getRealm() { public Logger getLogger() { return logger; } + + public boolean running() { + return QuartzAdaptor.this.running(); + } } } diff --git a/modules/quartz/src/main/java/org/jpos/q2/QuartzJobSupport.java b/modules/quartz/src/main/java/org/jpos/q2/QuartzJobSupport.java index 68f545d1b4..1d8e3c9ea3 100644 --- a/modules/quartz/src/main/java/org/jpos/q2/QuartzJobSupport.java +++ b/modules/quartz/src/main/java/org/jpos/q2/QuartzJobSupport.java @@ -31,6 +31,7 @@ public abstract class QuartzJobSupport implements Job, Configurable, Runnable { Configuration cfg; JobExecutionContext executionContext; Log log; + QuartzAdaptor.Q2Adaptor adaptor; public QuartzJobSupport() { super(); @@ -63,7 +64,7 @@ public void execute (JobExecutionContext ctx) throws JobExecutionException { Object o = ctx.getJobDetail().getJobDataMap().get("Q2"); try { if (o instanceof QuartzAdaptor.Q2Adaptor) { - QuartzAdaptor.Q2Adaptor adaptor = (QuartzAdaptor.Q2Adaptor) o; + adaptor = (QuartzAdaptor.Q2Adaptor) o; log = new Log(adaptor.getLogger(), adaptor.getRealm()); setConfiguration(adaptor.getConfiguration()); } @@ -72,4 +73,7 @@ public void execute (JobExecutionContext ctx) throws JobExecutionException { getLog().warn(e); } } + public boolean running() { + return adaptor == null || adaptor.running(); + } }