Update Java SDK

Author: stephanos

build.gradle

@@ -28,7 +28,7 @@ subprojects {
     ext {
         otelVersion = '1.30.1'
         otelVersionAlpha = "${otelVersion}-alpha"
-        javaSDKVersion = '1.26.1'
+        javaSDKVersion = '1.27.0'
         camelVersion = '3.22.1'
         jarVersion = '1.0.0'
     }

core/src/main/java/io/temporal/samples/countinterceptor/SimpleCountWorkerInterceptor.java

@@ -19,7 +19,9 @@
 
 package io.temporal.samples.countinterceptor;
 
+import io.nexusrpc.handler.OperationContext;
 import io.temporal.common.interceptors.ActivityInboundCallsInterceptor;
+import io.temporal.common.interceptors.NexusOperationInboundCallsInterceptor;
 import io.temporal.common.interceptors.WorkerInterceptor;
 import io.temporal.common.interceptors.WorkflowInboundCallsInterceptor;
 
@@ -34,4 +36,10 @@ public WorkflowInboundCallsInterceptor interceptWorkflow(WorkflowInboundCallsInt
   public ActivityInboundCallsInterceptor interceptActivity(ActivityInboundCallsInterceptor next) {
     return new SimpleCountActivityInboundCallsInterceptor(next);
   }
+
+  @Override
+  public NexusOperationInboundCallsInterceptor interceptNexusOperation(
+      OperationContext context, NexusOperationInboundCallsInterceptor next) {
+    return next;
+  }
 }

core/src/main/java/io/temporal/samples/earlyreturn/EarlyReturnClient.java

@@ -49,17 +49,13 @@ private static void runWorkflowWithUpdateWithStart(WorkflowClient client) {
 
     System.out.println("Starting workflow with UpdateWithStart");
 
-    UpdateWithStartWorkflowOperation<TxResult> updateOp =
-        UpdateWithStartWorkflowOperation.newBuilder(workflow::returnInitResult)
-            .setWaitForStage(WorkflowUpdateStage.COMPLETED) // Wait for update to complete
-            .build();
-
     TxResult updateResult = null;
     try {
-      WorkflowUpdateHandle<TxResult> updateHandle =
-          WorkflowClient.updateWithStart(workflow::processTransaction, txRequest, updateOp);
-
-      updateResult = updateHandle.getResultAsync().get();
+      updateResult =
+          WorkflowClient.executeUpdateWithStart(
+              workflow::returnInitResult,
+              UpdateOptions.<TxResult>newBuilder().build(),
+              new WithStartWorkflowOperation<>(workflow::processTransaction, txRequest));
 
       System.out.println(
           "Workflow initialized with result: "

core/src/main/java/io/temporal/samples/excludefrominterceptor/interceptor/MyWorkerInterceptor.java

@@ -19,7 +19,9 @@
 
 package io.temporal.samples.excludefrominterceptor.interceptor;
 
+import io.nexusrpc.handler.OperationContext;
 import io.temporal.common.interceptors.ActivityInboundCallsInterceptor;
+import io.temporal.common.interceptors.NexusOperationInboundCallsInterceptor;
 import io.temporal.common.interceptors.WorkerInterceptor;
 import io.temporal.common.interceptors.WorkflowInboundCallsInterceptor;
 import java.util.ArrayList;
@@ -49,4 +51,10 @@ public WorkflowInboundCallsInterceptor interceptWorkflow(WorkflowInboundCallsInt
   public ActivityInboundCallsInterceptor interceptActivity(ActivityInboundCallsInterceptor next) {
     return new MyActivityInboundCallsInterceptor(excludeActivityTypes, next);
   }
+
+  @Override
+  public NexusOperationInboundCallsInterceptor interceptNexusOperation(
+      OperationContext context, NexusOperationInboundCallsInterceptor next) {
+    return next;
+  }
 }

core/src/main/java/io/temporal/samples/retryonsignalinterceptor/RetryOnSignalWorkerInterceptor.java

@@ -19,7 +19,9 @@
 
 package io.temporal.samples.retryonsignalinterceptor;
 
+import io.nexusrpc.handler.OperationContext;
 import io.temporal.common.interceptors.ActivityInboundCallsInterceptor;
+import io.temporal.common.interceptors.NexusOperationInboundCallsInterceptor;
 import io.temporal.common.interceptors.WorkerInterceptor;
 import io.temporal.common.interceptors.WorkflowInboundCallsInterceptor;
 
@@ -34,4 +36,10 @@ public WorkflowInboundCallsInterceptor interceptWorkflow(WorkflowInboundCallsInt
   public ActivityInboundCallsInterceptor interceptActivity(ActivityInboundCallsInterceptor next) {
     return next;
   }
+
+  @Override
+  public NexusOperationInboundCallsInterceptor interceptNexusOperation(
+      OperationContext context, NexusOperationInboundCallsInterceptor next) {
+    return next;
+  }
 }