From bd7606691165848c41296c0db6590943b10be84f Mon Sep 17 00:00:00 2001 From: Ken Stevens Date: Wed, 8 Feb 2023 20:54:34 -0500 Subject: [PATCH] basic transactional scheduler working now --- .../src/main/java/ca/uhn/fhir/jpa/sched/BaseHapiScheduler.java | 2 +- .../java/ca/uhn/fhir/jpa/sched/BaseSchedulerServiceImpl.java | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/hapi-fhir-jpa/src/main/java/ca/uhn/fhir/jpa/sched/BaseHapiScheduler.java b/hapi-fhir-jpa/src/main/java/ca/uhn/fhir/jpa/sched/BaseHapiScheduler.java index c2820c61557..44be716fdf8 100644 --- a/hapi-fhir-jpa/src/main/java/ca/uhn/fhir/jpa/sched/BaseHapiScheduler.java +++ b/hapi-fhir-jpa/src/main/java/ca/uhn/fhir/jpa/sched/BaseHapiScheduler.java @@ -108,7 +108,7 @@ public abstract class BaseHapiScheduler implements IHapiScheduler { } @Nonnull - private String getThreadPrefix() { + protected String getThreadPrefix() { return myThreadNamePrefix + "-" + myInstanceName; } diff --git a/hapi-fhir-jpa/src/main/java/ca/uhn/fhir/jpa/sched/BaseSchedulerServiceImpl.java b/hapi-fhir-jpa/src/main/java/ca/uhn/fhir/jpa/sched/BaseSchedulerServiceImpl.java index bed64818402..95e1a8d84ec 100644 --- a/hapi-fhir-jpa/src/main/java/ca/uhn/fhir/jpa/sched/BaseSchedulerServiceImpl.java +++ b/hapi-fhir-jpa/src/main/java/ca/uhn/fhir/jpa/sched/BaseSchedulerServiceImpl.java @@ -171,7 +171,7 @@ public abstract class BaseSchedulerServiceImpl implements ISchedulerService { @EventListener(ContextClosedEvent.class) public void stop() { - ourLog.info("Shutting down task scheduler..."); + ourLog.info("Shutting down {} task scheduler...", myDefaultGroup); myStopping.set(true); myLocalScheduler.shutdown();