Let command be ExecutionModeAware

api/src/main/kotlin/dev/bpmcrafters/processengineapi/ExecutionMode.kt

@@ -0,0 +1,28 @@
+package dev.bpmcrafters.processengineapi
+
+/**
+ * Command execution mode.
+ * @since 1.6
+ */
+enum class ExecutionMode {
+  /**
+   * Alias for async.
+   */
+  DEFAULT,
+
+  /**
+   * Default async execution mode.
+   */
+  ASYNC,
+
+  /**
+   * Synchronous execution mode, adapter should use a specific thread pool
+   * to run the same thread and tx as the caller.
+   */
+  SYNC,
+
+  /**
+   * Special execution mode for preflight checks.
+   */
+  PREFLIGHT_CHECK
+}

api/src/main/kotlin/dev/bpmcrafters/processengineapi/ExecutionModeAware.kt

@@ -0,0 +1,13 @@
+package dev.bpmcrafters.processengineapi
+
+/**
+ * Interface to retrieve information of execution mode.
+ * @since 1.6
+ */
+interface ExecutionModeAware {
+  /**
+   * Retrieves execution mode.
+   * @return Execution mode.
+   */
+  fun executionMode(): ExecutionMode = ExecutionMode.DEFAULT
+}

api/src/main/kotlin/dev/bpmcrafters/processengineapi/correlation/CorrelateMessageCmd.kt

@@ -1,5 +1,6 @@
 package dev.bpmcrafters.processengineapi.correlation
 
+import dev.bpmcrafters.processengineapi.ExecutionModeAware
 import dev.bpmcrafters.processengineapi.PayloadSupplier
 
 /**
@@ -23,7 +24,7 @@ data class CorrelateMessageCmd(
    * Restrictions applied for this message.
    */
   val restrictions: Map<String, String> = emptyMap()
-) : PayloadSupplier by payloadSupplier {
+) : PayloadSupplier by payloadSupplier, ExecutionModeAware {
   /**
    * Constructs a correlation command by message name, payload and correlation.
    * @param messageName message name.

api/src/main/kotlin/dev/bpmcrafters/processengineapi/correlation/SendSignalCmd.kt

@@ -1,5 +1,6 @@
 package dev.bpmcrafters.processengineapi.correlation
 
+import dev.bpmcrafters.processengineapi.ExecutionModeAware
 import dev.bpmcrafters.processengineapi.PayloadSupplier
 
 /**
@@ -19,7 +20,7 @@ data class SendSignalCmd(
    * Restrictions of the signaling.
    */
   val restrictions: Map<String, String> = emptyMap()
-) : PayloadSupplier by payloadSupplier {
+) : PayloadSupplier by payloadSupplier, ExecutionModeAware {
   /**
    * Constructs a signal command by signal name, restrictions and given payload.
    * @param signalName signal name.

api/src/main/kotlin/dev/bpmcrafters/processengineapi/decision/DecisionByRefEvaluationCommand.kt

@@ -1,5 +1,6 @@
 package dev.bpmcrafters.processengineapi.decision
 
+import dev.bpmcrafters.processengineapi.ExecutionModeAware
 import dev.bpmcrafters.processengineapi.PayloadSupplier
 import java.util.function.Supplier
 

api/src/main/kotlin/dev/bpmcrafters/processengineapi/decision/DecisionEvaluationCommand.kt

@@ -1,9 +1,10 @@
 package dev.bpmcrafters.processengineapi.decision
 
+import dev.bpmcrafters.processengineapi.ExecutionModeAware
 import dev.bpmcrafters.processengineapi.PayloadSupplier
 
 /**
  * Interface for decision evaluation commands.
  * @since 1.4
  */
-interface DecisionEvaluationCommand : PayloadSupplier
+interface DecisionEvaluationCommand : PayloadSupplier, ExecutionModeAware

api/src/main/kotlin/dev/bpmcrafters/processengineapi/deploy/DeployBundleCommand.kt

@@ -1,5 +1,7 @@
 package dev.bpmcrafters.processengineapi.deploy
 
+import dev.bpmcrafters.processengineapi.ExecutionModeAware
+
 /**
  * Command to deploy a bundle of resources.
  * @since 0.0.1
@@ -13,4 +15,4 @@ data class DeployBundleCommand(
    * Optional tenant id.
    */
   val tenantId: String? = null
-)
+) : ExecutionModeAware

api/src/main/kotlin/dev/bpmcrafters/processengineapi/process/StartProcessCommand.kt

@@ -1,9 +1,10 @@
 package dev.bpmcrafters.processengineapi.process
 
+import dev.bpmcrafters.processengineapi.ExecutionModeAware
 import dev.bpmcrafters.processengineapi.PayloadSupplier
 
 /**
  * Interface for process start commands.
  * @since 0.0.1
  */
-interface StartProcessCommand : PayloadSupplier
+interface StartProcessCommand : PayloadSupplier, ExecutionModeAware

api/src/main/kotlin/dev/bpmcrafters/processengineapi/task/CompleteTaskByErrorCmd.kt

@@ -1,5 +1,6 @@
 package dev.bpmcrafters.processengineapi.task
 
+import dev.bpmcrafters.processengineapi.ExecutionModeAware
 import dev.bpmcrafters.processengineapi.PayloadSupplier
 
 /**
@@ -23,7 +24,7 @@ open class CompleteTaskByErrorCmd(
    * Payload supplier.
    */
   private val payloadSupplier: PayloadSupplier
-) : PayloadSupplier by payloadSupplier {
+) : PayloadSupplier by payloadSupplier, ExecutionModeAware {
   /**
    * Creates the complete command for a given task id and payload.
    * @param taskId id of the task to complete.

api/src/main/kotlin/dev/bpmcrafters/processengineapi/task/CompleteTaskCmd.kt

@@ -1,5 +1,6 @@
 package dev.bpmcrafters.processengineapi.task
 
+import dev.bpmcrafters.processengineapi.ExecutionModeAware
 import dev.bpmcrafters.processengineapi.PayloadSupplier
 
 /**
@@ -15,7 +16,7 @@ open class CompleteTaskCmd(
    * Payload supplier.
    */
   private val payloadSupplier: PayloadSupplier
-) : PayloadSupplier by payloadSupplier {
+) : PayloadSupplier by payloadSupplier, ExecutionModeAware {
 
   /**
    * Creates the complete command for a given task id and payload.

api/src/main/kotlin/dev/bpmcrafters/processengineapi/task/FailTaskCmd.kt

@@ -1,5 +1,6 @@
 package dev.bpmcrafters.processengineapi.task
 
+import dev.bpmcrafters.processengineapi.ExecutionModeAware
 import java.time.Duration
 
 /**
@@ -27,7 +28,7 @@ open class FailTaskCmd(
    * Optional retry backoff duration.
    */
   val retryBackoff: Duration?
-) {
+) : ExecutionModeAware {
   constructor(taskId: String, reason: String, errorDetails: String?)
     : this(taskId = taskId, reason = reason, errorDetails = errorDetails, null, null)
 }

api/src/main/kotlin/dev/bpmcrafters/processengineapi/task/ModifyTaskCmd.kt

@@ -1,9 +1,11 @@
 package dev.bpmcrafters.processengineapi.task
 
+import dev.bpmcrafters.processengineapi.ExecutionModeAware
+
 /**
  * Captures the intent of task modification.
  * @since 1.3
  */
-interface ModifyTaskCmd {
+interface ModifyTaskCmd : ExecutionModeAware {
   val taskId: String
 }