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

fixing small issues and updating to 1.15.0 

Signed-off-by: salaboy <Salaboy@gmail.com>
This commit is contained in:
salaboy 2025-08-18 10:56:58 +01:00
parent c02c8ffed1
commit f86ecdeefc
14 changed files with 16 additions and 36 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
bindings/java/sdk/batch/pom.xml
View File

@ -28,12 +28,12 @@
<dependency>
<groupId>io.dapr</groupId>
<artifactId>dapr-sdk-springboot</artifactId>
<version>1.14.1</version>
<version>1.15.0</version>
</dependency>
<dependency>
<groupId>io.dapr</groupId>
<artifactId>dapr-sdk</artifactId>
<version>1.14.1</version>
<version>1.15.0</version>
</dependency>
<dependency>
<groupId>org.projectlombok</groupId>

2
configuration/java/sdk/order-processor/pom.xml
View File

@ -17,7 +17,7 @@
<dependency>
<groupId>io.dapr</groupId>
<artifactId>dapr-sdk</artifactId>
<version>1.14.1</version>
<version>1.15.0</version>
</dependency>
<dependency>
<groupId>io.projectreactor</groupId>

2
pub_sub/java/sdk/checkout/pom.xml
View File

@ -17,7 +17,7 @@
<dependency>
<groupId>io.dapr</groupId>
<artifactId>dapr-sdk</artifactId>
<version>1.14.1</version>
<version>1.15.0</version>
</dependency>
<dependency>
<groupId>com.squareup.okhttp3</groupId>

4
pub_sub/java/sdk/order-processor/pom.xml
View File

@ -24,12 +24,12 @@
<dependency>
<groupId>io.dapr</groupId>
<artifactId>dapr-sdk-springboot</artifactId>
<version>1.14.1</version>
<version>1.15.0</version>
</dependency>
<dependency>
<groupId>io.dapr</groupId>
<artifactId>dapr-sdk</artifactId>
<version>1.14.1</version>
<version>1.15.0</version>
</dependency>
<dependency>
<groupId>org.projectlombok</groupId>

2
secrets_management/java/sdk/order-processor/pom.xml
View File

@ -20,7 +20,7 @@
<dependency>
<groupId>io.dapr</groupId>
<artifactId>dapr-sdk</artifactId>
<version>1.14.1</version>
<version>1.15.0</version>
</dependency>
</dependencies>
<build>

2
state_management/java/sdk/order-processor/pom.xml
View File

@ -17,7 +17,7 @@
<dependency>
<groupId>io.dapr</groupId>
<artifactId>dapr-sdk</artifactId>
<version>1.14.1</version>
<version>1.15.0</version>
</dependency>
<dependency>
<groupId>org.projectlombok</groupId>

0
tutorials/workflow/java/combined-patterns/order-workflow → tutorials/workflow/java/combined-patterns/order-workflow.http
View File

3
tutorials/workflow/java/combined-patterns/shipping-app/src/test/java/io/dapr/springboot/examples/DaprTestContainersConfig.java
View File

@ -105,7 +105,4 @@ public class DaprTestContainersConfig {
}
}
}

8
tutorials/workflow/java/combined-patterns/workflow-app/src/main/java/io/dapr/springboot/workflowapp/WorkflowAppRestController.java
View File

@ -50,6 +50,7 @@ public class WorkflowAppRestController {
public static final String DAPR_PUBSUB_COMPONENT = "shippingpubsub";
public static final String DAPR_PUBSUB_REGISTRATION_TOPIC = "shipment-registration-events";
public static final String SHIPMENT_REGISTERED_EVENT = "shipment-registered-event";
public static final String DAPR_PUBSUB_REGISTRATION_CONFIRMED_TOPIC = "shipment-registration-confirmed-events";
@Autowired
private DaprWorkflowClient daprWorkflowClient;
@ -84,7 +85,7 @@ public class WorkflowAppRestController {
* @param status ShipmentRegistrationStatus
*/
@PostMapping("shipmentRegistered")
@Topic(pubsubName = DAPR_PUBSUB_COMPONENT, name = "shipment-registration-confirmed-events")
@Topic(pubsubName = DAPR_PUBSUB_COMPONENT, name = DAPR_PUBSUB_REGISTRATION_CONFIRMED_TOPIC)
public void shipmentRegistered(@RequestBody CloudEvent<ShipmentRegistrationStatus> status){
logger.info("Shipment registered for order {}", status.getData());
daprWorkflowClient.raiseEvent(status.getData().orderId(), SHIPMENT_REGISTERED_EVENT, status.getData());
@ -126,10 +127,5 @@ public class WorkflowAppRestController {
return instanceState.readOutputAs(OrderStatus.class);
}
}

2
tutorials/workflow/java/fan-out-fan-in/README.md
View File

@ -74,7 +74,7 @@ graph LR
curl --request GET --url http://localhost:8080/output
```
5. The expected serialized output of the workflow is an array with two strings:
5. The expected serialized output of the workflow is one string (the shortest) from the array.
```txt
"["is"]"

6
tutorials/workflow/java/resiliency-and-compensation/src/main/java/io/dapr/springboot/examples/resiliency/DivisionActivity.java
View File

@ -19,15 +19,9 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.stereotype.Component;
/*
*/
@Component
public class DivisionActivity implements WorkflowActivity {
/*
*/
@Override
public Object run(WorkflowActivityContext ctx) {
Logger logger = LoggerFactory.getLogger(DivisionActivity.class);

6
tutorials/workflow/java/resiliency-and-compensation/src/main/java/io/dapr/springboot/examples/resiliency/MinusOneActivity.java
View File

@ -19,15 +19,9 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.stereotype.Component;
/*
*/
@Component
public class MinusOneActivity implements WorkflowActivity {
/*
*/
@Override
public Object run(WorkflowActivityContext ctx) {
Logger logger = LoggerFactory.getLogger(MinusOneActivity.class);

6
tutorials/workflow/java/resiliency-and-compensation/src/main/java/io/dapr/springboot/examples/resiliency/PlusOneActivity.java
View File

@ -19,15 +19,9 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.stereotype.Component;
/*
*/
@Component
public class PlusOneActivity implements WorkflowActivity {
/*
*/
@Override
public Object run(WorkflowActivityContext ctx) {
Logger logger = LoggerFactory.getLogger(PlusOneActivity.class);

5
tutorials/workflow/java/workflow-management/workflowmanagement.http
View File

@ -6,16 +6,21 @@
POST {{ apphost }}/start/{{counter}}
### Get the workflow status via the application
@instanceId={{startWorkflowRequest.response.body.instanceId}}
GET {{ apphost }}/status/{{ instanceId }}
### Suspend the workflow
@instanceId={{startWorkflowRequest.response.body.instanceId}}
POST {{ apphost }}/suspend/{{ instanceId }}
### Resume the workflow
@instanceId={{startWorkflowRequest.response.body.instanceId}}
POST {{ apphost }}/resume/{{ instanceId }}
### Terminate the workflow
@instanceId={{startWorkflowRequest.response.body.instanceId}}
POST {{ apphost }}/terminate/{{ instanceId }}
### Purge the workflow
@instanceId={{startWorkflowRequest.response.body.instanceId}}
DELETE {{ apphost }}/purge/{{ instanceId }}