44
55import com .azure .core .credential .TokenCredential ;
66import com .microsoft .durabletask .*;
7- import com .microsoft .durabletask .azuremanaged . client .DurableTaskSchedulerClientExtensions ;
8- import com .microsoft .durabletask .azuremanaged . worker .DurableTaskSchedulerWorkerExtensions ;
7+ import com .microsoft .durabletask .client . azuremanaged .DurableTaskSchedulerClientExtensions ;
8+ import com .microsoft .durabletask .worker . azuremanaged .DurableTaskSchedulerWorkerExtensions ;
99import org .springframework .boot .SpringApplication ;
1010import org .springframework .boot .autoconfigure .SpringBootApplication ;
1111import org .springframework .web .bind .annotation .*;
@@ -39,7 +39,7 @@ public class WebAppToDurableTaskSchedulerSample {
3939
4040 public static void main (String [] args ) {
4141 ConfigurableApplicationContext context = SpringApplication .run (WebAppToDurableTaskSchedulerSample .class , args );
42-
42+
4343 // Get the worker bean and start it
4444 DurableTaskGrpcWorker worker = context .getBean (DurableTaskGrpcWorker .class );
4545 worker .start ();
@@ -57,7 +57,7 @@ public TokenCredential tokenCredential() {
5757 public DurableTaskGrpcWorker durableTaskWorker (
5858 DurableTaskProperties properties ,
5959 TokenCredential tokenCredential ) {
60-
60+
6161 // Create worker using Azure-managed extensions
6262 DurableTaskGrpcWorkerBuilder workerBuilder = DurableTaskSchedulerWorkerExtensions .createWorkerBuilder (
6363 properties .getEndpoint (),
@@ -91,7 +91,7 @@ public TaskOrchestration create() {
9191
9292 // Ship order
9393 String shipmentResult = ctx .callActivity ("ShipOrder" , orderJson , String .class ).await ();
94-
94+
9595 // Return the final result
9696 ctx .complete ("{\" status\" : \" SUCCESS\" , " +
9797 "\" payment\" : " + paymentResult + ", " +
@@ -152,7 +152,7 @@ public TaskActivity create() {
152152 public DurableTaskClient durableTaskClient (
153153 DurableTaskProperties properties ,
154154 TokenCredential tokenCredential ) {
155-
155+
156156 // Create client using Azure-managed extensions
157157 return DurableTaskSchedulerClientExtensions .createClientBuilder (
158158 properties .getEndpoint (),
@@ -186,14 +186,14 @@ public OrderController(DurableTaskClient client) {
186186 @ PostMapping
187187 public String createOrder (@ RequestBody String orderJson ) throws Exception {
188188 String instanceId = client .scheduleNewOrchestrationInstance (
189- "ProcessOrderOrchestration" ,
189+ "ProcessOrderOrchestration" ,
190190 orderJson
191191 );
192192
193193 // Wait for the orchestration to complete with a timeout
194194 OrchestrationMetadata metadata = client .waitForInstanceCompletion (
195- instanceId ,
196- Duration .ofSeconds (30 ),
195+ instanceId ,
196+ Duration .ofSeconds (30 ),
197197 true
198198 );
199199
@@ -212,4 +212,4 @@ public String getOrder(@PathVariable String instanceId) throws Exception {
212212 }
213213 return metadata .readOutputAs (String .class );
214214 }
215- }
215+ }
0 commit comments