From 2c98035eca99c8a276f126d5c254f741d2cb81d7 Mon Sep 17 00:00:00 2001 From: Alejandro Revilla Date: Fri, 22 Jul 2016 16:25:01 -0300 Subject: [PATCH] add 'boolean running()' to QuartzJobSupport --- modules/quartz/src/main/java/org/jpos/q2/QuartzAdaptor.java | 4 ++++ .../quartz/src/main/java/org/jpos/q2/QuartzJobSupport.java | 6 +++++- 2 files changed, 9 insertions(+), 1 deletion(-) 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(); + } }