diff --git a/workflows/java/sdk/order-processor/pom.xml b/workflows/java/sdk/order-processor/pom.xml index c4fe0358..4e8b8e56 100644 --- a/workflows/java/sdk/order-processor/pom.xml +++ b/workflows/java/sdk/order-processor/pom.xml @@ -17,12 +17,12 @@ io.dapr dapr-sdk-workflows - 0.12.0 + 0.14.1 - org.slf4j - slf4j-simple - 2.0.13 + com.google.protobuf + protobuf-java + 3.25.5 diff --git a/workflows/java/sdk/order-processor/src/main/java/io/dapr/quickstarts/workflows/OrderProcessingWorkflow.java b/workflows/java/sdk/order-processor/src/main/java/io/dapr/quickstarts/workflows/OrderProcessingWorkflow.java index f0b85835..d8076382 100644 --- a/workflows/java/sdk/order-processor/src/main/java/io/dapr/quickstarts/workflows/OrderProcessingWorkflow.java +++ b/workflows/java/sdk/order-processor/src/main/java/io/dapr/quickstarts/workflows/OrderProcessingWorkflow.java @@ -18,7 +18,7 @@ import io.dapr.quickstarts.workflows.models.PaymentRequest; import io.dapr.workflows.Workflow; import io.dapr.workflows.WorkflowStub; -public class OrderProcessingWorkflow extends Workflow { +public class OrderProcessingWorkflow implements Workflow { @Override public WorkflowStub create() { diff --git a/workflows/java/sdk/order-processor/src/main/java/io/dapr/quickstarts/workflows/WorkflowConsoleApp.java b/workflows/java/sdk/order-processor/src/main/java/io/dapr/quickstarts/workflows/WorkflowConsoleApp.java index f48fad27..9e276096 100644 --- a/workflows/java/sdk/order-processor/src/main/java/io/dapr/quickstarts/workflows/WorkflowConsoleApp.java +++ b/workflows/java/sdk/order-processor/src/main/java/io/dapr/quickstarts/workflows/WorkflowConsoleApp.java @@ -55,10 +55,9 @@ public class WorkflowConsoleApp { builder.registerActivity(UpdateInventoryActivity.class); // Build and then start the workflow runtime pulling and executing tasks - try (WorkflowRuntime runtime = builder.build()) { - System.out.println("Start workflow runtime"); - runtime.start(false); - } + WorkflowRuntime runtime = builder.build(); + System.out.println("Start workflow runtime"); + runtime.start(false); InventoryItem inventory = prepareInventoryAndOrder(); @@ -66,7 +65,6 @@ public class WorkflowConsoleApp { try (workflowClient) { executeWorkflow(workflowClient, inventory); } - } private static void executeWorkflow(DaprWorkflowClient workflowClient, InventoryItem inventory) { diff --git a/workflows/java/sdk/order-processor/src/main/java/io/dapr/quickstarts/workflows/activities/NotifyActivity.java b/workflows/java/sdk/order-processor/src/main/java/io/dapr/quickstarts/workflows/activities/NotifyActivity.java index 7c4f71bc..50f4cde0 100644 --- a/workflows/java/sdk/order-processor/src/main/java/io/dapr/quickstarts/workflows/activities/NotifyActivity.java +++ b/workflows/java/sdk/order-processor/src/main/java/io/dapr/quickstarts/workflows/activities/NotifyActivity.java @@ -1,11 +1,11 @@ package io.dapr.quickstarts.workflows.activities; +import io.dapr.workflows.WorkflowActivity; +import io.dapr.workflows.WorkflowActivityContext; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import io.dapr.quickstarts.workflows.models.Notification; -import io.dapr.workflows.runtime.WorkflowActivity; -import io.dapr.workflows.runtime.WorkflowActivityContext; public class NotifyActivity implements WorkflowActivity { private static Logger logger = LoggerFactory.getLogger(NotifyActivity.class); diff --git a/workflows/java/sdk/order-processor/src/main/java/io/dapr/quickstarts/workflows/activities/ProcessPaymentActivity.java b/workflows/java/sdk/order-processor/src/main/java/io/dapr/quickstarts/workflows/activities/ProcessPaymentActivity.java index 17dbb837..b3bf6a90 100644 --- a/workflows/java/sdk/order-processor/src/main/java/io/dapr/quickstarts/workflows/activities/ProcessPaymentActivity.java +++ b/workflows/java/sdk/order-processor/src/main/java/io/dapr/quickstarts/workflows/activities/ProcessPaymentActivity.java @@ -1,11 +1,11 @@ package io.dapr.quickstarts.workflows.activities; +import io.dapr.workflows.WorkflowActivity; +import io.dapr.workflows.WorkflowActivityContext; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import io.dapr.quickstarts.workflows.models.PaymentRequest; -import io.dapr.workflows.runtime.WorkflowActivity; -import io.dapr.workflows.runtime.WorkflowActivityContext; public class ProcessPaymentActivity implements WorkflowActivity { private static Logger logger = LoggerFactory.getLogger(ProcessPaymentActivity.class); diff --git a/workflows/java/sdk/order-processor/src/main/java/io/dapr/quickstarts/workflows/activities/RequestApprovalActivity.java b/workflows/java/sdk/order-processor/src/main/java/io/dapr/quickstarts/workflows/activities/RequestApprovalActivity.java index 05d2e622..b46ab692 100644 --- a/workflows/java/sdk/order-processor/src/main/java/io/dapr/quickstarts/workflows/activities/RequestApprovalActivity.java +++ b/workflows/java/sdk/order-processor/src/main/java/io/dapr/quickstarts/workflows/activities/RequestApprovalActivity.java @@ -4,8 +4,8 @@ import org.slf4j.Logger; import org.slf4j.LoggerFactory; import io.dapr.quickstarts.workflows.models.OrderPayload; -import io.dapr.workflows.runtime.WorkflowActivity; -import io.dapr.workflows.runtime.WorkflowActivityContext; +import io.dapr.workflows.WorkflowActivity; +import io.dapr.workflows.WorkflowActivityContext; public class RequestApprovalActivity implements WorkflowActivity { private static Logger logger = LoggerFactory.getLogger(RequestApprovalActivity.class); diff --git a/workflows/java/sdk/order-processor/src/main/java/io/dapr/quickstarts/workflows/activities/UpdateInventoryActivity.java b/workflows/java/sdk/order-processor/src/main/java/io/dapr/quickstarts/workflows/activities/UpdateInventoryActivity.java index a8332441..6e8dea90 100644 --- a/workflows/java/sdk/order-processor/src/main/java/io/dapr/quickstarts/workflows/activities/UpdateInventoryActivity.java +++ b/workflows/java/sdk/order-processor/src/main/java/io/dapr/quickstarts/workflows/activities/UpdateInventoryActivity.java @@ -10,8 +10,8 @@ import io.dapr.quickstarts.workflows.models.InventoryItem; import io.dapr.quickstarts.workflows.models.InventoryRequest; import io.dapr.quickstarts.workflows.models.InventoryResult; import io.dapr.quickstarts.workflows.models.OrderPayload; -import io.dapr.workflows.runtime.WorkflowActivity; -import io.dapr.workflows.runtime.WorkflowActivityContext; +import io.dapr.workflows.WorkflowActivity; +import io.dapr.workflows.WorkflowActivityContext; public class UpdateInventoryActivity implements WorkflowActivity { private static Logger logger = LoggerFactory.getLogger(UpdateInventoryActivity.class); diff --git a/workflows/java/sdk/order-processor/src/main/java/io/dapr/quickstarts/workflows/activities/VerifyInventoryActivity.java b/workflows/java/sdk/order-processor/src/main/java/io/dapr/quickstarts/workflows/activities/VerifyInventoryActivity.java index 10f80060..c3ff520b 100644 --- a/workflows/java/sdk/order-processor/src/main/java/io/dapr/quickstarts/workflows/activities/VerifyInventoryActivity.java +++ b/workflows/java/sdk/order-processor/src/main/java/io/dapr/quickstarts/workflows/activities/VerifyInventoryActivity.java @@ -9,8 +9,8 @@ import io.dapr.client.domain.State; import io.dapr.quickstarts.workflows.models.InventoryItem; import io.dapr.quickstarts.workflows.models.InventoryRequest; import io.dapr.quickstarts.workflows.models.InventoryResult; -import io.dapr.workflows.runtime.WorkflowActivity; -import io.dapr.workflows.runtime.WorkflowActivityContext; +import io.dapr.workflows.WorkflowActivity; +import io.dapr.workflows.WorkflowActivityContext; public class VerifyInventoryActivity implements WorkflowActivity { private static Logger logger = LoggerFactory.getLogger(VerifyInventoryActivity.class);