diff --git a/sdk-workflows/src/main/java/io/dapr/workflows/runtime/WorkflowRuntime.java b/sdk-workflows/src/main/java/io/dapr/workflows/runtime/WorkflowRuntime.java index 09f831a563..9697d41b2a 100644 --- a/sdk-workflows/src/main/java/io/dapr/workflows/runtime/WorkflowRuntime.java +++ b/sdk-workflows/src/main/java/io/dapr/workflows/runtime/WorkflowRuntime.java @@ -16,6 +16,7 @@ import io.dapr.durabletask.DurableTaskGrpcWorker; import io.grpc.ManagedChannel; +import java.time.Duration; import java.util.concurrent.ExecutorService; import java.util.concurrent.TimeUnit; @@ -72,6 +73,14 @@ public void close() { this.closeSideCarChannel(); } + /** + * Immediately shuts down all resources associated with this instance. + */ + public void closeNow() { + this.executorService.shutdownNow(); + this.managedChannel.shutdownNow(); + } + private void closeSideCarChannel() { this.managedChannel.shutdown();