From 9c673d513d570c3d8be724394d0235e610f41b67 Mon Sep 17 00:00:00 2001 From: salaboy Date: Tue, 26 Aug 2025 11:39:52 +0100 Subject: [PATCH] throwing exceptions when setting appId Signed-off-by: salaboy --- .../io/dapr/workflows/WorkflowTaskOptions.java | 14 +++++++++++--- 1 file changed, 11 insertions(+), 3 deletions(-) diff --git a/sdk-workflows/src/main/java/io/dapr/workflows/WorkflowTaskOptions.java b/sdk-workflows/src/main/java/io/dapr/workflows/WorkflowTaskOptions.java index a0c01f86d..91e819010 100644 --- a/sdk-workflows/src/main/java/io/dapr/workflows/WorkflowTaskOptions.java +++ b/sdk-workflows/src/main/java/io/dapr/workflows/WorkflowTaskOptions.java @@ -17,7 +17,6 @@ public class WorkflowTaskOptions { private final WorkflowTaskRetryPolicy retryPolicy; private final WorkflowTaskRetryHandler retryHandler; - private final String appId; public WorkflowTaskOptions(WorkflowTaskRetryPolicy retryPolicy, WorkflowTaskRetryHandler retryHandler) { this(retryPolicy, retryHandler, null); @@ -38,6 +37,7 @@ public class WorkflowTaskOptions { */ public WorkflowTaskOptions(String appId) { this(null, null, appId); + throw new RuntimeException("Setting an appId is not supported in 1.15.x"); } /** @@ -50,15 +50,23 @@ public class WorkflowTaskOptions { public WorkflowTaskOptions(WorkflowTaskRetryPolicy retryPolicy, WorkflowTaskRetryHandler retryHandler, String appId) { this.retryPolicy = retryPolicy; this.retryHandler = retryHandler; - this.appId = appId; + if( appId != null){ + throw new RuntimeException("Setting an appId is not supported in 1.15.x"); + } } public WorkflowTaskOptions(WorkflowTaskRetryPolicy retryPolicy, String appId) { this(retryPolicy, null, appId); + if( appId != null){ + throw new RuntimeException("Setting an appId is not supported in 1.15.x"); + } } public WorkflowTaskOptions(WorkflowTaskRetryHandler retryHandler, String appId) { this(null, retryHandler, appId); + if( appId != null){ + throw new RuntimeException("Setting an appId is not supported in 1.15.x"); + } } public WorkflowTaskRetryPolicy getRetryPolicy() { @@ -70,7 +78,7 @@ public class WorkflowTaskOptions { } public String getAppId() { - return appId; + throw new RuntimeException("Setting an appId is not supported in 1.15.x"); } }