dapr
/
quickstarts
mirror of https://github.com/dapr/quickstarts.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Merge branch 'master' into users/svegiraju/quickstarts

This commit is contained in:
Alice Gibbons 2025-05-29 11:11:58 +02:00 committed by GitHub
parent 1926ca5718 13045c362c
commit ccca29e79d
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
8 changed files with 18 additions and 20 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
workflows/java/sdk/order-processor/pom.xml
View File

@ -17,12 +17,12 @@
<dependency> <dependency>
<groupId>io.dapr</groupId> <groupId>io.dapr</groupId>
<artifactId>dapr-sdk-workflows</artifactId> <artifactId>dapr-sdk-workflows</artifactId>
<version>0.12.0</version> <version>0.14.1</version>
</dependency> </dependency>
<dependency> <dependency>
<groupId>org.slf4j</groupId> <groupId>com.google.protobuf</groupId>
<artifactId>slf4j-simple</artifactId> <artifactId>protobuf-java</artifactId>
<version>2.0.13</version> <version>3.25.5</version>
</dependency> </dependency>
</dependencies> </dependencies>

2
workflows/java/sdk/order-processor/src/main/java/io/dapr/quickstarts/workflows/OrderProcessingWorkflow.java
View File

@ -18,7 +18,7 @@ import io.dapr.quickstarts.workflows.models.PaymentRequest;
import io.dapr.workflows.Workflow; import io.dapr.workflows.Workflow;
import io.dapr.workflows.WorkflowStub; import io.dapr.workflows.WorkflowStub;
public class OrderProcessingWorkflow extends Workflow { public class OrderProcessingWorkflow implements Workflow {
@Override @Override
public WorkflowStub create() { public WorkflowStub create() {

8
workflows/java/sdk/order-processor/src/main/java/io/dapr/quickstarts/workflows/WorkflowConsoleApp.java
View File

@ -55,10 +55,9 @@ public class WorkflowConsoleApp {
builder.registerActivity(UpdateInventoryActivity.class); builder.registerActivity(UpdateInventoryActivity.class);
// Build and then start the workflow runtime pulling and executing tasks // Build and then start the workflow runtime pulling and executing tasks
try (WorkflowRuntime runtime = builder.build()) { WorkflowRuntime runtime = builder.build();
System.out.println("Start workflow runtime"); System.out.println("Start workflow runtime");
runtime.start(false); runtime.start(false);
}
InventoryItem inventory = prepareInventoryAndOrder(); InventoryItem inventory = prepareInventoryAndOrder();
@ -66,7 +65,6 @@ public class WorkflowConsoleApp {
try (workflowClient) { try (workflowClient) {
executeWorkflow(workflowClient, inventory); executeWorkflow(workflowClient, inventory);
} }
} }
private static void executeWorkflow(DaprWorkflowClient workflowClient, InventoryItem inventory) { private static void executeWorkflow(DaprWorkflowClient workflowClient, InventoryItem inventory) {

4
workflows/java/sdk/order-processor/src/main/java/io/dapr/quickstarts/workflows/activities/NotifyActivity.java
View File

@ -1,11 +1,11 @@
package io.dapr.quickstarts.workflows.activities; package io.dapr.quickstarts.workflows.activities;
import io.dapr.workflows.WorkflowActivity;
import io.dapr.workflows.WorkflowActivityContext;
import org.slf4j.Logger; import org.slf4j.Logger;
import org.slf4j.LoggerFactory; import org.slf4j.LoggerFactory;
import io.dapr.quickstarts.workflows.models.Notification; import io.dapr.quickstarts.workflows.models.Notification;
import io.dapr.workflows.runtime.WorkflowActivity;
import io.dapr.workflows.runtime.WorkflowActivityContext;
public class NotifyActivity implements WorkflowActivity { public class NotifyActivity implements WorkflowActivity {
private static Logger logger = LoggerFactory.getLogger(NotifyActivity.class); private static Logger logger = LoggerFactory.getLogger(NotifyActivity.class);

4
workflows/java/sdk/order-processor/src/main/java/io/dapr/quickstarts/workflows/activities/ProcessPaymentActivity.java
View File

@ -1,11 +1,11 @@
package io.dapr.quickstarts.workflows.activities; package io.dapr.quickstarts.workflows.activities;
import io.dapr.workflows.WorkflowActivity;
import io.dapr.workflows.WorkflowActivityContext;
import org.slf4j.Logger; import org.slf4j.Logger;
import org.slf4j.LoggerFactory; import org.slf4j.LoggerFactory;
import io.dapr.quickstarts.workflows.models.PaymentRequest; import io.dapr.quickstarts.workflows.models.PaymentRequest;
import io.dapr.workflows.runtime.WorkflowActivity;
import io.dapr.workflows.runtime.WorkflowActivityContext;
public class ProcessPaymentActivity implements WorkflowActivity { public class ProcessPaymentActivity implements WorkflowActivity {
private static Logger logger = LoggerFactory.getLogger(ProcessPaymentActivity.class); private static Logger logger = LoggerFactory.getLogger(ProcessPaymentActivity.class);

4
workflows/java/sdk/order-processor/src/main/java/io/dapr/quickstarts/workflows/activities/RequestApprovalActivity.java
View File

@ -4,8 +4,8 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory; import org.slf4j.LoggerFactory;
import io.dapr.quickstarts.workflows.models.OrderPayload; import io.dapr.quickstarts.workflows.models.OrderPayload;
import io.dapr.workflows.runtime.WorkflowActivity; import io.dapr.workflows.WorkflowActivity;
import io.dapr.workflows.runtime.WorkflowActivityContext; import io.dapr.workflows.WorkflowActivityContext;
public class RequestApprovalActivity implements WorkflowActivity { public class RequestApprovalActivity implements WorkflowActivity {
private static Logger logger = LoggerFactory.getLogger(RequestApprovalActivity.class); private static Logger logger = LoggerFactory.getLogger(RequestApprovalActivity.class);

4
workflows/java/sdk/order-processor/src/main/java/io/dapr/quickstarts/workflows/activities/UpdateInventoryActivity.java
View File

@ -10,8 +10,8 @@ import io.dapr.quickstarts.workflows.models.InventoryItem;
import io.dapr.quickstarts.workflows.models.InventoryRequest; import io.dapr.quickstarts.workflows.models.InventoryRequest;
import io.dapr.quickstarts.workflows.models.InventoryResult; import io.dapr.quickstarts.workflows.models.InventoryResult;
import io.dapr.quickstarts.workflows.models.OrderPayload; import io.dapr.quickstarts.workflows.models.OrderPayload;
import io.dapr.workflows.runtime.WorkflowActivity; import io.dapr.workflows.WorkflowActivity;
import io.dapr.workflows.runtime.WorkflowActivityContext; import io.dapr.workflows.WorkflowActivityContext;
public class UpdateInventoryActivity implements WorkflowActivity { public class UpdateInventoryActivity implements WorkflowActivity {
private static Logger logger = LoggerFactory.getLogger(UpdateInventoryActivity.class); private static Logger logger = LoggerFactory.getLogger(UpdateInventoryActivity.class);

4
workflows/java/sdk/order-processor/src/main/java/io/dapr/quickstarts/workflows/activities/VerifyInventoryActivity.java
View File

@ -9,8 +9,8 @@ import io.dapr.client.domain.State;
import io.dapr.quickstarts.workflows.models.InventoryItem; import io.dapr.quickstarts.workflows.models.InventoryItem;
import io.dapr.quickstarts.workflows.models.InventoryRequest; import io.dapr.quickstarts.workflows.models.InventoryRequest;
import io.dapr.quickstarts.workflows.models.InventoryResult; import io.dapr.quickstarts.workflows.models.InventoryResult;
import io.dapr.workflows.runtime.WorkflowActivity; import io.dapr.workflows.WorkflowActivity;
import io.dapr.workflows.runtime.WorkflowActivityContext; import io.dapr.workflows.WorkflowActivityContext;
public class VerifyInventoryActivity implements WorkflowActivity { public class VerifyInventoryActivity implements WorkflowActivity {
private static Logger logger = LoggerFactory.getLogger(VerifyInventoryActivity.class); private static Logger logger = LoggerFactory.getLogger(VerifyInventoryActivity.class);