From 82f1f56967ca3a6de6daced7a2c5a005fd9ff23b Mon Sep 17 00:00:00 2001
From: Moqui Industrial <729502+moqui-industrial@users.noreply.github.com>
Date: Sun, 21 Jun 2026 11:35:20 +0200
Subject: [PATCH 1/2] Add test#ScheduleService and test#Echo for distributed
 executor testing

Demonstrates <service-schedule> and <cancel-scheduled-service> XML actions
with distribute="true". test#Echo logs the executing node runtime path and
thread name so cluster-wide task distribution is directly observable.
Expose via REST at /rest/s1/example/test/scheduleService (anonymous-view).
---
 service/example.rest.xml                  |  5 +++++
 service/moqui/example/ExampleServices.xml | 21 +++++++++++++++++++++
 2 files changed, 26 insertions(+)

diff --git a/service/example.rest.xml b/service/example.rest.xml
index c0a3dd9..027d164 100644
--- a/service/example.rest.xml
+++ b/service/example.rest.xml
@@ -77,4 +77,9 @@ along with this software (see the LICENSE.md file). If not, see
             </resource>
         </id>
     </resource>
+    <resource name="test" require-authentication="anonymous-view">
+        <resource name="scheduleService">
+            <method type="post"><service name="moqui.example.ExampleServices.test#ScheduleService"/></method>
+        </resource>
+    </resource>
 </resource>
diff --git a/service/moqui/example/ExampleServices.xml b/service/moqui/example/ExampleServices.xml
index 5fd7bda..196aeef 100644
--- a/service/moqui/example/ExampleServices.xml
+++ b/service/moqui/example/ExampleServices.xml
@@ -194,4 +194,25 @@ along with this software (see the LICENSE.md file). If not, see
             <auto-parameters entity-name="moqui.example.Example"/>
         </out-parameters>
     </service>
+
+    <!-- ========== Example Scheduled Services ========== -->
+    <service verb="test" noun="ScheduleService" authenticate="false" allow-remote="true">
+        <in-parameters>
+            <parameter name="taskName" default-value="hz-dist-test"/>
+        </in-parameters>
+        <actions>
+            <service-schedule name="moqui.example.ExampleServices.test#Echo"
+                task-name="${taskName}" type="at-fixed-rate" distribute="true" initial-delay="500"
+                polling-interval="200" duration="15000" in-map="[taskName:taskName]"/>
+            <cancel-scheduled-service task-name="${taskName}" cancel-delay="10000"/>
+        </actions>
+    </service>
+    <service verb="test" noun="Echo" authenticate="false">
+        <in-parameters>
+            <parameter name="taskName"/>
+        </in-parameters>
+        <actions>
+            <log level="info" message="HZ Test Echo Service task=${taskName} runtime=${ec.factory.runtimePath} thread=${Thread.currentThread().name}"/>
+        </actions>
+    </service>
 </services>

From 1ba41cfba8acaa6328ab68a1b1cca1600c4fca31 Mon Sep 17 00:00:00 2001
From: Moqui Industrial <729502+moqui-industrial@users.noreply.github.com>
Date: Sun, 21 Jun 2026 11:35:20 +0200
Subject: [PATCH 2/2] Add test#ScheduleRealJob for distributed executor cluster
 validation

test#ScheduleRealJob schedules mantle.order.OrderServices.autoApprove#OrdersDelayed
as a one-shot distribute=true task via the Hazelcast distributed executor.
test#RunAutoApproveDistributed wraps the real service with log lines that report
which node executes it, making cross-node distribution directly observable in logs.

REST endpoint: POST /rest/s1/example/test/scheduleRealJob
---
 service/example.rest.xml                  |  3 +++
 service/moqui/example/ExampleServices.xml | 20 ++++++++++++++++++++
 2 files changed, 23 insertions(+)

diff --git a/service/example.rest.xml b/service/example.rest.xml
index 027d164..463222c 100644
--- a/service/example.rest.xml
+++ b/service/example.rest.xml
@@ -81,5 +81,8 @@ along with this software (see the LICENSE.md file). If not, see
         <resource name="scheduleService">
             <method type="post"><service name="moqui.example.ExampleServices.test#ScheduleService"/></method>
         </resource>
+        <resource name="scheduleRealJob">
+            <method type="post"><service name="moqui.example.ExampleServices.test#ScheduleRealJob"/></method>
+        </resource>
     </resource>
 </resource>
diff --git a/service/moqui/example/ExampleServices.xml b/service/moqui/example/ExampleServices.xml
index 196aeef..17471f0 100644
--- a/service/moqui/example/ExampleServices.xml
+++ b/service/moqui/example/ExampleServices.xml
@@ -215,4 +215,24 @@ along with this software (see the LICENSE.md file). If not, see
             <log level="info" message="HZ Test Echo Service task=${taskName} runtime=${ec.factory.runtimePath} thread=${Thread.currentThread().name}"/>
         </actions>
     </service>
+
+    <service verb="test" noun="ScheduleRealJob" authenticate="false" allow-remote="true">
+        <in-parameters>
+            <parameter name="taskName" default-value="hz-autoapprove-test"/>
+        </in-parameters>
+        <actions>
+            <service-schedule name="moqui.example.ExampleServices.test#RunAutoApproveDistributed"
+                task-name="${taskName}" distribute="true" initial-delay="2000" in-map="[taskName:taskName]"/>
+        </actions>
+    </service>
+    <service verb="test" noun="RunAutoApproveDistributed" authenticate="false">
+        <in-parameters>
+            <parameter name="taskName"/>
+        </in-parameters>
+        <actions>
+            <log level="info" message="[HZ-DIST-JOB] autoApprove#OrdersDelayed task=${taskName} runtime=${ec.factory.runtimePath} thread=${Thread.currentThread().name}"/>
+            <service-call name="mantle.order.OrderServices.autoApprove#OrdersDelayed" ignore-error="true"/>
+            <log level="info" message="[HZ-DIST-JOB] autoApprove#OrdersDelayed completed on runtime=${ec.factory.runtimePath}"/>
+        </actions>
+    </service>
 </services>