We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 02fa2c8 commit 6094775Copy full SHA for 6094775
1 file changed
sdk-workflows/src/main/java/io/dapr/workflows/runtime/WorkflowRuntime.java
@@ -16,6 +16,7 @@
16
import io.dapr.durabletask.DurableTaskGrpcWorker;
17
import io.grpc.ManagedChannel;
18
19
+import java.time.Duration;
20
import java.util.concurrent.ExecutorService;
21
import java.util.concurrent.TimeUnit;
22
@@ -72,6 +73,14 @@ public void close() {
72
73
this.closeSideCarChannel();
74
}
75
76
+ /**
77
+ * Immediately shuts down all resources associated with this instance.
78
+ */
79
+ public void closeNow() {
80
+ this.executorService.shutdownNow();
81
+ this.managedChannel.shutdownNow();
82
+ }
83
+
84
private void closeSideCarChannel() {
85
this.managedChannel.shutdown();
86
0 commit comments