File tree Expand file tree Collapse file tree 8 files changed +18
-20
lines changed
workflows/java/sdk/order-processor
src/main/java/io/dapr/quickstarts/workflows Expand file tree Collapse file tree 8 files changed +18
-20
lines changed Original file line number Diff line number Diff line change 1717 <dependency >
1818 <groupId >io.dapr</groupId >
1919 <artifactId >dapr-sdk-workflows</artifactId >
20- <version >0.12.0 </version >
20+ <version >0.14.1 </version >
2121 </dependency >
2222 <dependency >
23- <groupId >org.slf4j </groupId >
24- <artifactId >slf4j-simple </artifactId >
25- <version >2.0.13 </version >
23+ <groupId >com.google.protobuf </groupId >
24+ <artifactId >protobuf-java </artifactId >
25+ <version >3.25.5 </version >
2626 </dependency >
2727 </dependencies >
2828
Original file line number Diff line number Diff line change 1818import io .dapr .workflows .Workflow ;
1919import io .dapr .workflows .WorkflowStub ;
2020
21- public class OrderProcessingWorkflow extends Workflow {
21+ public class OrderProcessingWorkflow implements Workflow {
2222
2323 @ Override
2424 public WorkflowStub create () {
Original file line number Diff line number Diff line change @@ -55,18 +55,16 @@ public static void main(String[] args) throws Exception {
5555 builder .registerActivity (UpdateInventoryActivity .class );
5656
5757 // Build and then start the workflow runtime pulling and executing tasks
58- try (WorkflowRuntime runtime = builder .build ()) {
59- System .out .println ("Start workflow runtime" );
60- runtime .start (false );
61- }
58+ WorkflowRuntime runtime = builder .build ();
59+ System .out .println ("Start workflow runtime" );
60+ runtime .start (false );
6261
6362 InventoryItem inventory = prepareInventoryAndOrder ();
6463
6564 DaprWorkflowClient workflowClient = new DaprWorkflowClient ();
6665 try (workflowClient ) {
6766 executeWorkflow (workflowClient , inventory );
6867 }
69-
7068 }
7169
7270 private static void executeWorkflow (DaprWorkflowClient workflowClient , InventoryItem inventory ) {
Original file line number Diff line number Diff line change 11package io .dapr .quickstarts .workflows .activities ;
22
3+ import io .dapr .workflows .WorkflowActivity ;
4+ import io .dapr .workflows .WorkflowActivityContext ;
35import org .slf4j .Logger ;
46import org .slf4j .LoggerFactory ;
57
68import io .dapr .quickstarts .workflows .models .Notification ;
7- import io .dapr .workflows .runtime .WorkflowActivity ;
8- import io .dapr .workflows .runtime .WorkflowActivityContext ;
99
1010public class NotifyActivity implements WorkflowActivity {
1111 private static Logger logger = LoggerFactory .getLogger (NotifyActivity .class );
Original file line number Diff line number Diff line change 11package io .dapr .quickstarts .workflows .activities ;
22
3+ import io .dapr .workflows .WorkflowActivity ;
4+ import io .dapr .workflows .WorkflowActivityContext ;
35import org .slf4j .Logger ;
46import org .slf4j .LoggerFactory ;
57
68import io .dapr .quickstarts .workflows .models .PaymentRequest ;
7- import io .dapr .workflows .runtime .WorkflowActivity ;
8- import io .dapr .workflows .runtime .WorkflowActivityContext ;
99
1010public class ProcessPaymentActivity implements WorkflowActivity {
1111 private static Logger logger = LoggerFactory .getLogger (ProcessPaymentActivity .class );
Original file line number Diff line number Diff line change 44import org .slf4j .LoggerFactory ;
55
66import io .dapr .quickstarts .workflows .models .OrderPayload ;
7- import io .dapr .workflows .runtime . WorkflowActivity ;
8- import io .dapr .workflows .runtime . WorkflowActivityContext ;
7+ import io .dapr .workflows .WorkflowActivity ;
8+ import io .dapr .workflows .WorkflowActivityContext ;
99
1010public class RequestApprovalActivity implements WorkflowActivity {
1111 private static Logger logger = LoggerFactory .getLogger (RequestApprovalActivity .class );
Original file line number Diff line number Diff line change 1010import io .dapr .quickstarts .workflows .models .InventoryRequest ;
1111import io .dapr .quickstarts .workflows .models .InventoryResult ;
1212import io .dapr .quickstarts .workflows .models .OrderPayload ;
13- import io .dapr .workflows .runtime . WorkflowActivity ;
14- import io .dapr .workflows .runtime . WorkflowActivityContext ;
13+ import io .dapr .workflows .WorkflowActivity ;
14+ import io .dapr .workflows .WorkflowActivityContext ;
1515
1616public class UpdateInventoryActivity implements WorkflowActivity {
1717 private static Logger logger = LoggerFactory .getLogger (UpdateInventoryActivity .class );
Original file line number Diff line number Diff line change 99import io .dapr .quickstarts .workflows .models .InventoryItem ;
1010import io .dapr .quickstarts .workflows .models .InventoryRequest ;
1111import io .dapr .quickstarts .workflows .models .InventoryResult ;
12- import io .dapr .workflows .runtime . WorkflowActivity ;
13- import io .dapr .workflows .runtime . WorkflowActivityContext ;
12+ import io .dapr .workflows .WorkflowActivity ;
13+ import io .dapr .workflows .WorkflowActivityContext ;
1414
1515public class VerifyInventoryActivity implements WorkflowActivity {
1616 private static Logger logger = LoggerFactory .getLogger (VerifyInventoryActivity .class );
You can’t perform that action at this time.
0 commit comments