From 715fe23a4c3eef1d10c4ad5f41749c13c97729ee Mon Sep 17 00:00:00 2001 From: Alan Paxton Date: Wed, 23 Sep 2026 15:08:38 +0100 Subject: [PATCH] Scheduler only valid when a broker exists --- .../exist/xquery/modules/scheduler/DeleteScheduledJob.java | 5 +---- .../exist/xquery/modules/scheduler/ScheduleFunctions.java | 3 +-- 2 files changed, 2 insertions(+), 6 deletions(-) diff --git a/extensions/modules/scheduler/src/main/java/org/exist/xquery/modules/scheduler/DeleteScheduledJob.java b/extensions/modules/scheduler/src/main/java/org/exist/xquery/modules/scheduler/DeleteScheduledJob.java index 0114a5b724..9425b40379 100644 --- a/extensions/modules/scheduler/src/main/java/org/exist/xquery/modules/scheduler/DeleteScheduledJob.java +++ b/extensions/modules/scheduler/src/main/java/org/exist/xquery/modules/scheduler/DeleteScheduledJob.java @@ -61,8 +61,6 @@ public class DeleteScheduledJob extends BasicFunction new FunctionReturnSequenceType( Type.BOOLEAN, Cardinality.EXACTLY_ONE, "a boolean value indicating success or failure on deleting the named job." ) ); - private Scheduler scheduler = null; - /** * DeleteScheduledJob Constructor. * @@ -72,8 +70,6 @@ public class DeleteScheduledJob extends BasicFunction public DeleteScheduledJob( XQueryContext context, FunctionSignature signature ) { super( context, signature ); - - scheduler = context.getBroker().getBrokerPool().getScheduler(); } /** @@ -99,6 +95,7 @@ public Sequence eval( Sequence[] args, Sequence contextSequence ) throws XPathEx return( BooleanValue.FALSE ); } + Scheduler scheduler = context.getBroker().getBrokerPool().getScheduler(); return( BooleanValue.valueOf( scheduler.deleteJob( jobName, UserJob.JOB_GROUP ) ) ); } } diff --git a/extensions/modules/scheduler/src/main/java/org/exist/xquery/modules/scheduler/ScheduleFunctions.java b/extensions/modules/scheduler/src/main/java/org/exist/xquery/modules/scheduler/ScheduleFunctions.java index c7eb29954c..df82c6888a 100644 --- a/extensions/modules/scheduler/src/main/java/org/exist/xquery/modules/scheduler/ScheduleFunctions.java +++ b/extensions/modules/scheduler/src/main/java/org/exist/xquery/modules/scheduler/ScheduleFunctions.java @@ -257,8 +257,6 @@ public class ScheduleFunctions extends BasicFunction public ScheduleFunctions( XQueryContext context, FunctionSignature signature ) { super( context, signature ); - - scheduler = context.getBroker().getBrokerPool().getScheduler(); } /** @@ -352,6 +350,7 @@ else if( isCalledAs( SCHEDULE_JAVA_CRON_JOB ) || isCalledAs( SCHEDULE_JAVA_PERIO if( job != null ) { + Scheduler scheduler = context.getBroker().getBrokerPool().getScheduler(); if( isCron ) { //schedule the job