dapr
/
java-sdk
mirror of https://github.com/dapr/java-sdk.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

throwing exceptions when setting appId 

Signed-off-by: salaboy <Salaboy@gmail.com>
This commit is contained in:
salaboy 2025-08-26 11:39:52 +01:00
parent b0a7a1b3ee
commit 9c673d513d
1 changed files with 11 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
sdk-workflows/src/main/java/io/dapr/workflows/WorkflowTaskOptions.java
View File

@ -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");
}
}