diff --git a/.github/workflows/build.yml b/.github/workflows/build.yml index aef774933c..f3de37f15f 100644 --- a/.github/workflows/build.yml +++ b/.github/workflows/build.yml @@ -117,9 +117,9 @@ jobs: GOARCH: amd64 GOPROXY: https://proxy.golang.org JDK_VER: ${{ matrix.java }} - DAPR_CLI_VER: 1.17.0-rc.2 - DAPR_RUNTIME_VER: 1.17.0-rc.10 - DAPR_INSTALL_URL: https://raw.githubusercontent.com/dapr/cli/v1.17.0-rc.2/install/install.sh + DAPR_CLI_VER: 1.17.0 + DAPR_RUNTIME_VER: 1.17.0 + DAPR_INSTALL_URL: https://raw.githubusercontent.com/dapr/cli/v1.17.0/install/install.sh DAPR_CLI_REF: DAPR_REF: TOXIPROXY_URL: https://github.com/Shopify/toxiproxy/releases/download/v2.5.0/toxiproxy-server-linux-amd64 diff --git a/.github/workflows/validate.yml b/.github/workflows/validate.yml index 75de3eb2aa..24effa0fa0 100644 --- a/.github/workflows/validate.yml +++ b/.github/workflows/validate.yml @@ -37,9 +37,9 @@ jobs: GOARCH: amd64 GOPROXY: https://proxy.golang.org JDK_VER: ${{ matrix.java }} - DAPR_CLI_VER: 1.17.0-rc.2 - DAPR_RUNTIME_VER: 1.17.0-rc.10 - DAPR_INSTALL_URL: https://raw.githubusercontent.com/dapr/cli/v1.17.0-rc.2/install/install.sh + DAPR_CLI_VER: 1.17.0 + DAPR_RUNTIME_VER: 1.17.0 + DAPR_INSTALL_URL: https://raw.githubusercontent.com/dapr/cli/v1.17.0/install/install.sh DAPR_CLI_REF: DAPR_REF: steps: diff --git a/examples/src/main/java/io/dapr/examples/actors/README.md b/examples/src/main/java/io/dapr/examples/actors/README.md index c202e2087d..6f1425a097 100644 --- a/examples/src/main/java/io/dapr/examples/actors/README.md +++ b/examples/src/main/java/io/dapr/examples/actors/README.md @@ -260,49 +260,49 @@ dapr run --resources-path ./components/actors --app-id demoactorclient -- java - Once running, the `demoactorservice` logs will start displaying the different steps: First, we can see actors being activated and the `say` method being invoked: ```text -== APP == 2023-05-23 11:04:47,348 {HH:mm:ss.SSS} [http-nio-3000-exec-5] INFO io.dapr.actors.ActorTrace - Actor:a855706e-f477-4530-9bff-d7b1cd2988f8 Activating ... +2023-05-23 11:04:47,348 {HH:mm:ss.SSS} [http-nio-3000-exec-5] INFO io.dapr.actors.ActorTrace - Actor:a855706e-f477-4530-9bff-d7b1cd2988f8 Activating ... -== APP == 2023-05-23 11:04:47,348 {HH:mm:ss.SSS} [http-nio-3000-exec-6] INFO io.dapr.actors.ActorTrace - Actor:4720f646-baaa-4fae-86dd-aec2fc2ead6e Activating ... +2023-05-23 11:04:47,348 {HH:mm:ss.SSS} [http-nio-3000-exec-6] INFO io.dapr.actors.ActorTrace - Actor:4720f646-baaa-4fae-86dd-aec2fc2ead6e Activating ... -== APP == 2023-05-23 11:04:47,348 {HH:mm:ss.SSS} [http-nio-3000-exec-7] INFO io.dapr.actors.ActorTrace - Actor:d54592a5-5b5b-4925-8974-6cf309fbdbbf Activating ... +2023-05-23 11:04:47,348 {HH:mm:ss.SSS} [http-nio-3000-exec-7] INFO io.dapr.actors.ActorTrace - Actor:d54592a5-5b5b-4925-8974-6cf309fbdbbf Activating ... -== APP == 2023-05-23 11:04:47,348 {HH:mm:ss.SSS} [http-nio-3000-exec-5] INFO io.dapr.actors.ActorTrace - Actor:a855706e-f477-4530-9bff-d7b1cd2988f8 Activated +2023-05-23 11:04:47,348 {HH:mm:ss.SSS} [http-nio-3000-exec-5] INFO io.dapr.actors.ActorTrace - Actor:a855706e-f477-4530-9bff-d7b1cd2988f8 Activated -== APP == 2023-05-23 11:04:47,348 {HH:mm:ss.SSS} [http-nio-3000-exec-7] INFO io.dapr.actors.ActorTrace - Actor:d54592a5-5b5b-4925-8974-6cf309fbdbbf Activated +2023-05-23 11:04:47,348 {HH:mm:ss.SSS} [http-nio-3000-exec-7] INFO io.dapr.actors.ActorTrace - Actor:d54592a5-5b5b-4925-8974-6cf309fbdbbf Activated -== APP == 2023-05-23 11:04:47,348 {HH:mm:ss.SSS} [http-nio-3000-exec-6] INFO io.dapr.actors.ActorTrace - Actor:4720f646-baaa-4fae-86dd-aec2fc2ead6e Activated +2023-05-23 11:04:47,348 {HH:mm:ss.SSS} [http-nio-3000-exec-6] INFO io.dapr.actors.ActorTrace - Actor:4720f646-baaa-4fae-86dd-aec2fc2ead6e Activated -== APP == Server say method for actor d54592a5-5b5b-4925-8974-6cf309fbdbbf: Message #2 received from actor at index 1 with ID d54592a5-5b5b-4925-8974-6cf309fbdbbf @ 2023-05-23 11:04:48.459 +Server say method for actor d54592a5-5b5b-4925-8974-6cf309fbdbbf: Message #2 received from actor at index 1 with ID d54592a5-5b5b-4925-8974-6cf309fbdbbf @ 2023-05-23 11:04:48.459 -== APP == Server say method for actor 4720f646-baaa-4fae-86dd-aec2fc2ead6e: Message #4 received from actor at index 2 with ID 4720f646-baaa-4fae-86dd-aec2fc2ead6e @ 2023-05-23 11:04:48.695 +Server say method for actor 4720f646-baaa-4fae-86dd-aec2fc2ead6e: Message #4 received from actor at index 2 with ID 4720f646-baaa-4fae-86dd-aec2fc2ead6e @ 2023-05-23 11:04:48.695 -== APP == Server say method for actor d54592a5-5b5b-4925-8974-6cf309fbdbbf: Message #3 received from actor at index 1 with ID d54592a5-5b5b-4925-8974-6cf309fbdbbf @ 2023-05-23 11:04:48.708 +Server say method for actor d54592a5-5b5b-4925-8974-6cf309fbdbbf: Message #3 received from actor at index 1 with ID d54592a5-5b5b-4925-8974-6cf309fbdbbf @ 2023-05-23 11:04:48.708 ``` Then we can see reminders and timers in action: ```text -== APP == Server timer triggered with state ping! {0} for actor a855706e-f477-4530-9bff-d7b1cd2988f8@ 2023-05-23 11:04:49.021 +Server timer triggered with state ping! {0} for actor a855706e-f477-4530-9bff-d7b1cd2988f8@ 2023-05-23 11:04:49.021 -== APP == Server timer triggered with state ping! {1} for actor d54592a5-5b5b-4925-8974-6cf309fbdbbf@ 2023-05-23 11:04:49.021 +Server timer triggered with state ping! {1} for actor d54592a5-5b5b-4925-8974-6cf309fbdbbf@ 2023-05-23 11:04:49.021 -== APP == Reminder myremind with state {2} triggered for actor 4720f646-baaa-4fae-86dd-aec2fc2ead6e @ 2023-05-23 11:04:52.012 +Reminder myremind with state {2} triggered for actor 4720f646-baaa-4fae-86dd-aec2fc2ead6e @ 2023-05-23 11:04:52.012 -== APP == Reminder myremind with state {1} triggered for actor d54592a5-5b5b-4925-8974-6cf309fbdbbf @ 2023-05-23 11:04:52.012 +Reminder myremind with state {1} triggered for actor d54592a5-5b5b-4925-8974-6cf309fbdbbf @ 2023-05-23 11:04:52.012 -== APP == Reminder myremind with state {0} triggered for actor a855706e-f477-4530-9bff-d7b1cd2988f8 @ 2023-05-23 11:04:52.012 +Reminder myremind with state {0} triggered for actor a855706e-f477-4530-9bff-d7b1cd2988f8 @ 2023-05-23 11:04:52.012 ``` Finally, the console for `demoactorclient` got the service responses: ```text -== APP == Reply 2023-05-23 11:04:49.288 received from actor at index 0 with ID a855706e-f477-4530-9bff-d7b1cd2988f8 +Reply 2023-05-23 11:04:49.288 received from actor at index 0 with ID a855706e-f477-4530-9bff-d7b1cd2988f8 -== APP == Reply 2023-05-23 11:04:49.408 received from actor at index 0 with ID a855706e-f477-4530-9bff-d7b1cd2988f8 +Reply 2023-05-23 11:04:49.408 received from actor at index 0 with ID a855706e-f477-4530-9bff-d7b1cd2988f8 -== APP == Reply 2023-05-23 11:04:49.515 received from actor at index 1 with ID d54592a5-5b5b-4925-8974-6cf309fbdbbf +Reply 2023-05-23 11:04:49.515 received from actor at index 1 with ID d54592a5-5b5b-4925-8974-6cf309fbdbbf -== APP == Reply 2023-05-23 11:04:49.740 received from actor at index 0 with ID a855706e-f477-4530-9bff-d7b1cd2988f8 +Reply 2023-05-23 11:04:49.740 received from actor at index 0 with ID a855706e-f477-4530-9bff-d7b1cd2988f8 -== APP == Reply 2023-05-23 11:04:49.863 received from actor at index 2 with ID 4720f646-baaa-4fae-86dd-aec2fc2ead6e +Reply 2023-05-23 11:04:49.863 received from actor at index 2 with ID 4720f646-baaa-4fae-86dd-aec2fc2ead6e ``` For more details on Dapr SpringBoot integration, please refer to [Dapr Spring Boot](https://github.com/dapr/java-sdk/blob/master/sdk-tests/src/test/java/io/dapr/it/actors/services/springboot/DaprApplication.java) Application implementation. diff --git a/examples/src/main/java/io/dapr/examples/bindings/http/README.md b/examples/src/main/java/io/dapr/examples/bindings/http/README.md index 74a4176ad5..97d0cff529 100644 --- a/examples/src/main/java/io/dapr/examples/bindings/http/README.md +++ b/examples/src/main/java/io/dapr/examples/bindings/http/README.md @@ -130,10 +130,10 @@ Execute the following command to run the Input Binding example: @@ -200,10 +200,10 @@ Execute the following command to run the Output Binding example: @@ -217,13 +217,13 @@ dapr run --resources-path ./components/bindings --app-id outputbinding -- java - Once running, the OutputBindingExample should print the output as follows: ```txt -== APP == sending a class with message: Message #0 +sending a class with message: Message #0 -== APP == sending a plain string: Message #1 +sending a plain string: Message #1 -== APP == sending a class with message: Message #2 +sending a class with message: Message #2 -== APP == sending a plain string: Message #3 +sending a plain string: Message #3 ``` Events have been sent. @@ -231,13 +231,13 @@ Events have been sent. Once running, the InputBindingExample should print the output as follows: ```txt -== APP == Received message through binding: {"message":"Message #0"} +Received message through binding: {"message":"Message #0"} -== APP == Received message through binding: "Message #1" +Received message through binding: "Message #1" -== APP == Received message through binding: {"message":"Message #2"} +Received message through binding: {"message":"Message #2"} -== APP == Received message through binding: "Message #3" +Received message through binding: "Message #3" ``` Events have been retrieved from the binding. diff --git a/examples/src/main/java/io/dapr/examples/configuration/README.md b/examples/src/main/java/io/dapr/examples/configuration/README.md index 525edf7302..3338ed62bb 100644 --- a/examples/src/main/java/io/dapr/examples/configuration/README.md +++ b/examples/src/main/java/io/dapr/examples/configuration/README.md @@ -144,14 +144,14 @@ Use the following command to run this example- @@ -81,13 +81,13 @@ dapr run --app-id exception-example -- java -jar target/dapr-java-sdk-examples-e Once running, the State Client Example should print the output as follows: ```txt -== APP == Error code: ERR_PUBSUB_NOT_FOUND +Error code: ERR_PUBSUB_NOT_FOUND -== APP == Error message: ERR_PUBSUB_NOT_FOUND: pubsub unknown_pubsub is not found +Error message: ERR_PUBSUB_NOT_FOUND: pubsub unknown_pubsub is not found -== APP == Reason: DAPR_PUBSUB_NOT_FOUND +Reason: DAPR_PUBSUB_NOT_FOUND -== APP == Error payload size: 116 +Error payload size: 116 ... ``` diff --git a/examples/src/main/java/io/dapr/examples/invoke/grpc/README.md b/examples/src/main/java/io/dapr/examples/invoke/grpc/README.md index 25588979c2..57555189bd 100644 --- a/examples/src/main/java/io/dapr/examples/invoke/grpc/README.md +++ b/examples/src/main/java/io/dapr/examples/invoke/grpc/README.md @@ -77,8 +77,8 @@ Now run the service code: @@ -123,9 +123,9 @@ Finally, open a new command line terminal and run the client code to send some m diff --git a/examples/src/main/java/io/dapr/examples/invoke/http/README.md b/examples/src/main/java/io/dapr/examples/invoke/http/README.md index 55757d7377..60a1b42877 100644 --- a/examples/src/main/java/io/dapr/examples/invoke/http/README.md +++ b/examples/src/main/java/io/dapr/examples/invoke/http/README.md @@ -104,8 +104,8 @@ Use the following command to execute the demo service example: @@ -152,9 +152,9 @@ Execute the follow script in order to run the InvokeClient example, passing two @@ -168,11 +168,11 @@ dapr run --app-id invokeclient -- java -jar target/dapr-java-sdk-examples-exec.j Finally, the console for `invokeclient` should output: ```text -== APP == "message one" received +"message one" received -== APP == "message two" received +"message two" received -== APP == Done +Done ``` diff --git a/examples/src/main/java/io/dapr/examples/jobs/README.md b/examples/src/main/java/io/dapr/examples/jobs/README.md index 392c0969bb..65ac38f4db 100644 --- a/examples/src/main/java/io/dapr/examples/jobs/README.md +++ b/examples/src/main/java/io/dapr/examples/jobs/README.md @@ -96,8 +96,8 @@ Use the following command to run this example- @@ -65,11 +65,11 @@ dapr run --resources-path ./components/lock --app-id lockgrpc --log-level debug ### Sample output ``` -== APP == Using preview client... -== APP == *******trying to get a free distributed lock******** -== APP == Lock result -> SUCCESS -== APP == *******unlock a distributed lock******** -== APP == Unlock result -> SUCCESS +Using preview client... +*******trying to get a free distributed lock******** +Lock result -> SUCCESS +*******unlock a distributed lock******** +Unlock result -> SUCCESS ``` ### Cleanup diff --git a/examples/src/main/java/io/dapr/examples/pubsub/README.md b/examples/src/main/java/io/dapr/examples/pubsub/README.md index 5492ae0cef..bbeb37194a 100644 --- a/examples/src/main/java/io/dapr/examples/pubsub/README.md +++ b/examples/src/main/java/io/dapr/examples/pubsub/README.md @@ -195,8 +195,8 @@ Execute the following command to run the Publisher example: @@ -212,27 +212,27 @@ Once running, the Publisher should print the output as follows: ```txt ✅ You're up and running! Both Dapr and your app logs will appear here. -== APP == Published message: This is message #0 +Published message: This is message #0 -== APP == Published message: This is message #1 +Published message: This is message #1 -== APP == Published message: This is message #2 +Published message: This is message #2 -== APP == Published message: This is message #3 +Published message: This is message #3 -== APP == Published message: This is message #4 +Published message: This is message #4 -== APP == Published message: This is message #5 +Published message: This is message #5 -== APP == Published message: This is message #6 +Published message: This is message #6 -== APP == Published message: This is message #7 +Published message: This is message #7 -== APP == Published message: This is message #8 +Published message: This is message #8 -== APP == Published message: This is message #9 +Published message: This is message #9 -== APP == Done. +Done. ``` @@ -241,35 +241,35 @@ Messages have been published in the topic. Once running, the Subscriber should print the output as follows: ```txt -== APP == Subscriber got: This is message #3 -== APP == Subscriber got: {"id":"1f646657-0032-4797-b59b-c57b4f40743b","source":"publisher","type":"com.dapr.event.sent","specversion":"1.0","datacontenttype":"application/json","data":"This is message #3","expiration":"2020-12-24T05:29:12Z"} +Subscriber got: This is message #3 +Subscriber got: {"id":"1f646657-0032-4797-b59b-c57b4f40743b","source":"publisher","type":"com.dapr.event.sent","specversion":"1.0","datacontenttype":"application/json","data":"This is message #3","expiration":"2020-12-24T05:29:12Z"} -== APP == Subscriber got: This is message #8 -== APP == Subscriber got: {"id":"a22b97ce-9008-4fba-8b57-c3c3e1f031b6","source":"publisher","type":"com.dapr.event.sent","specversion":"1.0","datacontenttype":"application/json","data":"This is message #8","expiration":"2020-12-24T05:29:15Z"} +Subscriber got: This is message #8 +Subscriber got: {"id":"a22b97ce-9008-4fba-8b57-c3c3e1f031b6","source":"publisher","type":"com.dapr.event.sent","specversion":"1.0","datacontenttype":"application/json","data":"This is message #8","expiration":"2020-12-24T05:29:15Z"} -== APP == Subscriber got: This is message #0 -== APP == Subscriber got: {"id":"abb2f110-6862-49f7-8c8d-189f6dcd177d","source":"publisher","type":"com.dapr.event.sent","specversion":"1.0","datacontenttype":"application/json","data":"This is message #0","expiration":"2020-12-24T05:29:11Z"} +Subscriber got: This is message #0 +Subscriber got: {"id":"abb2f110-6862-49f7-8c8d-189f6dcd177d","source":"publisher","type":"com.dapr.event.sent","specversion":"1.0","datacontenttype":"application/json","data":"This is message #0","expiration":"2020-12-24T05:29:11Z"} -== APP == Subscriber got: This is message #7 -== APP == Subscriber got: {"id":"043f31d3-c13a-4a02-ac89-64ecca946598","source":"publisher","type":"com.dapr.event.sent","specversion":"1.0","datacontenttype":"application/json","data":"This is message #7","expiration":"2020-12-24T05:29:14Z"} +Subscriber got: This is message #7 +Subscriber got: {"id":"043f31d3-c13a-4a02-ac89-64ecca946598","source":"publisher","type":"com.dapr.event.sent","specversion":"1.0","datacontenttype":"application/json","data":"This is message #7","expiration":"2020-12-24T05:29:14Z"} -== APP == Subscriber got: This is message #2 -== APP == Subscriber got: {"id":"acc554f4-7109-4c31-9374-0e5936b90180","source":"publisher","type":"com.dapr.event.sent","specversion":"1.0","datacontenttype":"application/json","data":"This is message #2","expiration":"2020-12-24T05:29:12Z"} +Subscriber got: This is message #2 +Subscriber got: {"id":"acc554f4-7109-4c31-9374-0e5936b90180","source":"publisher","type":"com.dapr.event.sent","specversion":"1.0","datacontenttype":"application/json","data":"This is message #2","expiration":"2020-12-24T05:29:12Z"} -== APP == Subscriber got: This is message #9 -== APP == Subscriber got: {"id":"8b3ad160-368d-4b0f-9925-8fa2a2fbf5ca","source":"publisher","type":"com.dapr.event.sent","specversion":"1.0","datacontenttype":"application/json","data":"This is message #9","expiration":"2020-12-24T05:29:15Z"} +Subscriber got: This is message #9 +Subscriber got: {"id":"8b3ad160-368d-4b0f-9925-8fa2a2fbf5ca","source":"publisher","type":"com.dapr.event.sent","specversion":"1.0","datacontenttype":"application/json","data":"This is message #9","expiration":"2020-12-24T05:29:15Z"} -== APP == Subscriber got: This is message #1 -== APP == Subscriber got: {"id":"e41d4512-511a-4a2b-80f3-a0a4d091c9a5","source":"publisher","type":"com.dapr.event.sent","specversion":"1.0","datacontenttype":"application/json","data":"This is message #1","expiration":"2020-12-24T05:29:11Z"} +Subscriber got: This is message #1 +Subscriber got: {"id":"e41d4512-511a-4a2b-80f3-a0a4d091c9a5","source":"publisher","type":"com.dapr.event.sent","specversion":"1.0","datacontenttype":"application/json","data":"This is message #1","expiration":"2020-12-24T05:29:11Z"} -== APP == Subscriber got: This is message #4 -== APP == Subscriber got: {"id":"33e21664-128e-4fc4-b5c4-ed257f758336","source":"publisher","type":"com.dapr.event.sent","specversion":"1.0","datacontenttype":"application/json","data":"This is message #4","expiration":"2020-12-24T05:29:13Z"} +Subscriber got: This is message #4 +Subscriber got: {"id":"33e21664-128e-4fc4-b5c4-ed257f758336","source":"publisher","type":"com.dapr.event.sent","specversion":"1.0","datacontenttype":"application/json","data":"This is message #4","expiration":"2020-12-24T05:29:13Z"} -== APP == Subscriber got: This is message #6 -== APP == Subscriber got: {"id":"bd14f1ee-ca6b-47f7-8130-dd1e6de5b03c","source":"publisher","type":"com.dapr.event.sent","specversion":"1.0","datacontenttype":"application/json","data":"This is message #6","expiration":"2020-12-24T05:29:14Z"} +Subscriber got: This is message #6 +Subscriber got: {"id":"bd14f1ee-ca6b-47f7-8130-dd1e6de5b03c","source":"publisher","type":"com.dapr.event.sent","specversion":"1.0","datacontenttype":"application/json","data":"This is message #6","expiration":"2020-12-24T05:29:14Z"} -== APP == Subscriber got: This is message #5 -== APP == Subscriber got: {"id":"acc57cd6-71da-4ba3-9a12-9c921ca49af7","source":"publisher","type":"com.dapr.event.sent","specversion":"1.0","datacontenttype":"application/json","data":"This is message #5","expiration":"2020-12-24T05:29:13Z"} +Subscriber got: This is message #5 +Subscriber got: {"id":"acc57cd6-71da-4ba3-9a12-9c921ca49af7","source":"publisher","type":"com.dapr.event.sent","specversion":"1.0","datacontenttype":"application/json","data":"This is message #5","expiration":"2020-12-24T05:29:13Z"} ``` @@ -397,7 +397,7 @@ Execute the following command to run the BulkPublisher example: name: Run Bulk Publisher match_order: sequential expected_stdout_lines: - - '== APP == Published the set of messages in a single call to Dapr' + - 'Published the set of messages in a single call to Dapr' background: true --> @@ -412,20 +412,20 @@ Once running, the BulkPublisher should print the output as follows: ```txt ✅ You're up and running! Both Dapr and your app logs will appear here. -== APP == Using Dapr client... -== APP == Constructing the list of messages to publish -== APP == Going to publish message : This is message #0 -== APP == Going to publish message : This is message #1 -== APP == Going to publish message : This is message #2 -== APP == Going to publish message : This is message #3 -== APP == Going to publish message : This is message #4 -== APP == Going to publish message : This is message #5 -== APP == Going to publish message : This is message #6 -== APP == Going to publish message : This is message #7 -== APP == Going to publish message : This is message #8 -== APP == Going to publish message : This is message #9 -== APP == Published the set of messages in a single call to Dapr -== APP == Done +Using Dapr client... +Constructing the list of messages to publish +Going to publish message : This is message #0 +Going to publish message : This is message #1 +Going to publish message : This is message #2 +Going to publish message : This is message #3 +Going to publish message : This is message #4 +Going to publish message : This is message #5 +Going to publish message : This is message #6 +Going to publish message : This is message #7 +Going to publish message : This is message #8 +Going to publish message : This is message #9 +Published the set of messages in a single call to Dapr +Done ``` @@ -434,26 +434,26 @@ Messages have been published in the topic. The Subscriber started previously [here](#running-the-subscriber) should print the output as follows: ```txt -== APP == Subscriber got from bulk published topic: This is message #1 -== APP == Subscriber got: {"id":"323935ed-d8db-4ea2-ba28-52352b1d1b34","source":"bulk-publisher","type":"com.dapr.event.sent","specversion":"1.0","datacontenttype":"text/plain","data":"This is message #1","data_base64":null} -== APP == Subscriber got from bulk published topic: This is message #0 -== APP == Subscriber got: {"id":"bb2f4833-0473-446b-a6cc-04a36de5ac0a","source":"bulk-publisher","type":"com.dapr.event.sent","specversion":"1.0","datacontenttype":"text/plain","data":"This is message #0","data_base64":null} -== APP == Subscriber got from bulk published topic: This is message #5 -== APP == Subscriber got: {"id":"07bad175-4be4-4beb-a983-4def2eba5768","source":"bulk-publisher","type":"com.dapr.event.sent","specversion":"1.0","datacontenttype":"text/plain","data":"This is message #5","data_base64":null} -== APP == Subscriber got from bulk published topic: This is message #6 -== APP == Subscriber got: {"id":"b99fba4d-732a-4d18-bf10-b37916dedfb1","source":"bulk-publisher","type":"com.dapr.event.sent","specversion":"1.0","datacontenttype":"text/plain","data":"This is message #6","data_base64":null} -== APP == Subscriber got from bulk published topic: This is message #2 -== APP == Subscriber got: {"id":"2976f254-7859-449e-b66c-57fab4a72aef","source":"bulk-publisher","type":"com.dapr.event.sent","specversion":"1.0","datacontenttype":"text/plain","data":"This is message #2","data_base64":null} -== APP == Subscriber got from bulk published topic: This is message #3 -== APP == Subscriber got: {"id":"f21ff2b5-4842-481d-9a96-e4c299d1c463","source":"bulk-publisher","type":"com.dapr.event.sent","specversion":"1.0","datacontenttype":"text/plain","data":"This is message #3","data_base64":null} -== APP == Subscriber got from bulk published topic: This is message #4 -== APP == Subscriber got: {"id":"4bf50438-e576-4f5f-bb40-bd31c716ad02","source":"bulk-publisher","type":"com.dapr.event.sent","specversion":"1.0","datacontenttype":"text/plain","data":"This is message #4","data_base64":null} -== APP == Subscriber got from bulk published topic: This is message #7 -== APP == Subscriber got: {"id":"f0c8b53b-7935-478e-856b-164d329d25ab","source":"bulk-publisher","type":"com.dapr.event.sent","specversion":"1.0","datacontenttype":"text/plain","data":"This is message #7","data_base64":null} -== APP == Subscriber got from bulk published topic: This is message #9 -== APP == Subscriber got: {"id":"b280569f-cc29-471f-9cb7-682d8d6bd553","source":"bulk-publisher","type":"com.dapr.event.sent","specversion":"1.0","datacontenttype":"text/plain","data":"This is message #9","data_base64":null} -== APP == Subscriber got from bulk published topic: This is message #8 -== APP == Subscriber got: {"id":"df20d841-296e-4c6b-9dcb-dd17920538e7","source":"bulk-publisher","type":"com.dapr.event.sent","specversion":"1.0","datacontenttype":"text/plain","data":"This is message #8","data_base64":null} +Subscriber got from bulk published topic: This is message #1 +Subscriber got: {"id":"323935ed-d8db-4ea2-ba28-52352b1d1b34","source":"bulk-publisher","type":"com.dapr.event.sent","specversion":"1.0","datacontenttype":"text/plain","data":"This is message #1","data_base64":null} +Subscriber got from bulk published topic: This is message #0 +Subscriber got: {"id":"bb2f4833-0473-446b-a6cc-04a36de5ac0a","source":"bulk-publisher","type":"com.dapr.event.sent","specversion":"1.0","datacontenttype":"text/plain","data":"This is message #0","data_base64":null} +Subscriber got from bulk published topic: This is message #5 +Subscriber got: {"id":"07bad175-4be4-4beb-a983-4def2eba5768","source":"bulk-publisher","type":"com.dapr.event.sent","specversion":"1.0","datacontenttype":"text/plain","data":"This is message #5","data_base64":null} +Subscriber got from bulk published topic: This is message #6 +Subscriber got: {"id":"b99fba4d-732a-4d18-bf10-b37916dedfb1","source":"bulk-publisher","type":"com.dapr.event.sent","specversion":"1.0","datacontenttype":"text/plain","data":"This is message #6","data_base64":null} +Subscriber got from bulk published topic: This is message #2 +Subscriber got: {"id":"2976f254-7859-449e-b66c-57fab4a72aef","source":"bulk-publisher","type":"com.dapr.event.sent","specversion":"1.0","datacontenttype":"text/plain","data":"This is message #2","data_base64":null} +Subscriber got from bulk published topic: This is message #3 +Subscriber got: {"id":"f21ff2b5-4842-481d-9a96-e4c299d1c463","source":"bulk-publisher","type":"com.dapr.event.sent","specversion":"1.0","datacontenttype":"text/plain","data":"This is message #3","data_base64":null} +Subscriber got from bulk published topic: This is message #4 +Subscriber got: {"id":"4bf50438-e576-4f5f-bb40-bd31c716ad02","source":"bulk-publisher","type":"com.dapr.event.sent","specversion":"1.0","datacontenttype":"text/plain","data":"This is message #4","data_base64":null} +Subscriber got from bulk published topic: This is message #7 +Subscriber got: {"id":"f0c8b53b-7935-478e-856b-164d329d25ab","source":"bulk-publisher","type":"com.dapr.event.sent","specversion":"1.0","datacontenttype":"text/plain","data":"This is message #7","data_base64":null} +Subscriber got from bulk published topic: This is message #9 +Subscriber got: {"id":"b280569f-cc29-471f-9cb7-682d8d6bd553","source":"bulk-publisher","type":"com.dapr.event.sent","specversion":"1.0","datacontenttype":"text/plain","data":"This is message #9","data_base64":null} +Subscriber got from bulk published topic: This is message #8 +Subscriber got: {"id":"df20d841-296e-4c6b-9dcb-dd17920538e7","source":"bulk-publisher","type":"com.dapr.event.sent","specversion":"1.0","datacontenttype":"text/plain","data":"This is message #8","data_base64":null} ``` > Note: the Redis pubsub component does not have a native bulk publish implementation, and uses Dapr runtime's default bulk publish implementation which is concurrent. Therefore, the order of the events that are published are not guaranteed. @@ -465,8 +465,8 @@ You can also run the publisher to publish messages to `testingtopicbulk` topic, @@ -479,27 +479,27 @@ dapr run --resources-path ./components/pubsub --app-id publisher -- java -jar ta Once running, the Publisher should print the same output as seen [above](#running-the-publisher). The Subscriber should print the output as follows: ```txt -== APP == Bulk Subscriber got 10 messages. -== APP == Bulk Subscriber message has entry ID: d4d81c57-d75c-4a22-a747-e907099ca135 -== APP == Bulk Subscriber got: This is message #0 -== APP == Bulk Subscriber message has entry ID: f109c837-f7c8-4839-8d71-2df9c467875c -== APP == Bulk Subscriber got: This is message #1 -== APP == Bulk Subscriber message has entry ID: d735044f-1320-43e1-bd41-787ad9d26427 -== APP == Bulk Subscriber got: This is message #2 -== APP == Bulk Subscriber message has entry ID: afe74e5a-1a2b-498a-beca-7a6383141ccf -== APP == Bulk Subscriber got: This is message #3 -== APP == Bulk Subscriber message has entry ID: 1df3fa51-d137-4749-891d-973ce58f1e1c -== APP == Bulk Subscriber got: This is message #4 -== APP == Bulk Subscriber message has entry ID: ecab82bd-77be-40a1-8b62-2dbb3388d726 -== APP == Bulk Subscriber got: This is message #5 -== APP == Bulk Subscriber message has entry ID: 49a63916-ed09-4101-969e-13a860e35c55 -== APP == Bulk Subscriber got: This is message #6 -== APP == Bulk Subscriber message has entry ID: 897ec32c-ad74-4512-8979-ee0a455433e8 -== APP == Bulk Subscriber got: This is message #7 -== APP == Bulk Subscriber message has entry ID: 67367edc-27a6-4c8c-9e39-31caa0f74b2d -== APP == Bulk Subscriber got: This is message #8 -== APP == Bulk Subscriber message has entry ID: f134d21f-0a05-408d-977c-1397b999e908 -== APP == Bulk Subscriber got: This is message #9 +Bulk Subscriber got 10 messages. +Bulk Subscriber message has entry ID: d4d81c57-d75c-4a22-a747-e907099ca135 +Bulk Subscriber got: This is message #0 +Bulk Subscriber message has entry ID: f109c837-f7c8-4839-8d71-2df9c467875c +Bulk Subscriber got: This is message #1 +Bulk Subscriber message has entry ID: d735044f-1320-43e1-bd41-787ad9d26427 +Bulk Subscriber got: This is message #2 +Bulk Subscriber message has entry ID: afe74e5a-1a2b-498a-beca-7a6383141ccf +Bulk Subscriber got: This is message #3 +Bulk Subscriber message has entry ID: 1df3fa51-d137-4749-891d-973ce58f1e1c +Bulk Subscriber got: This is message #4 +Bulk Subscriber message has entry ID: ecab82bd-77be-40a1-8b62-2dbb3388d726 +Bulk Subscriber got: This is message #5 +Bulk Subscriber message has entry ID: 49a63916-ed09-4101-969e-13a860e35c55 +Bulk Subscriber got: This is message #6 +Bulk Subscriber message has entry ID: 897ec32c-ad74-4512-8979-ee0a455433e8 +Bulk Subscriber got: This is message #7 +Bulk Subscriber message has entry ID: 67367edc-27a6-4c8c-9e39-31caa0f74b2d +Bulk Subscriber got: This is message #8 +Bulk Subscriber message has entry ID: f134d21f-0a05-408d-977c-1397b999e908 +Bulk Subscriber got: This is message #9 ``` @@ -589,12 +589,12 @@ Execute the following command to run the HTTP Subscriber example: name: Run Http Subscriber match_order: none expected_stdout_lines: - - '== APP == Subscriber got: This is message #1' - - '== APP == Subscriber got: This is message #2' - - '== APP == Subscriber got from bulk published topic: This is message #2' - - '== APP == Subscriber got from bulk published topic: This is message #3' - - '== APP == Bulk Subscriber got: This is message #1' - - '== APP == Bulk Subscriber got: This is message #2' + - 'Subscriber got: This is message #1' + - 'Subscriber got: This is message #2' + - 'Subscriber got from bulk published topic: This is message #2' + - 'Subscriber got from bulk published topic: This is message #3' + - 'Bulk Subscriber got: This is message #1' + - 'Bulk Subscriber got: This is message #2' background: true sleep: 15 --> @@ -708,10 +708,10 @@ Execute the following command to run the gRPC Subscriber example: name: Run gRPC Subscriber match_order: none expected_stdout_lines: - - '== APP == Subscriber got: This is message #1' - - '== APP == Subscriber got: This is message #2' - - '== APP == Bulk Subscriber got: "This is message #1"' - - '== APP == Bulk Subscriber got: "This is message #2"' + - 'Subscriber got: This is message #1' + - 'Subscriber got: This is message #2' + - 'Bulk Subscriber got: "This is message #1"' + - 'Bulk Subscriber got: "This is message #2"' background: true sleep: 15 --> @@ -728,10 +728,10 @@ dapr run --resources-path ./components/pubsub --app-id subscriber --app-port 300 Use the follow command to start a publisher @@ -745,25 +745,25 @@ dapr run --resources-path ./components/pubsub --app-id publisher -- java -jar ta Messages will be subscribed by the gRPC Subscriber and will print the output as follows: ``` -== APP == Subscriber got: This is message #0 -== APP == Subscriber got: This is message #1 -== APP == Subscriber got: This is message #2 -== APP == Subscriber got: This is message #3 -== APP == Subscriber got: This is message #4 -== APP == Subscriber got: This is message #5 -== APP == Subscriber got: This is message #6 -== APP == Subscriber got: This is message #7 -== APP == Subscriber got: This is message #8 -== APP == Subscriber got: This is message #9 +Subscriber got: This is message #0 +Subscriber got: This is message #1 +Subscriber got: This is message #2 +Subscriber got: This is message #3 +Subscriber got: This is message #4 +Subscriber got: This is message #5 +Subscriber got: This is message #6 +Subscriber got: This is message #7 +Subscriber got: This is message #8 +Subscriber got: This is message #9 ``` If you run a bulk publisher using following command @@ -777,32 +777,32 @@ dapr run --resources-path ./components/pubsub --app-id publisher -- java -jar ta The console will print the output: ``` -== APP == Bulk Subscriber received 2 messages. -== APP == Bulk Subscriber message has entry ID: 0c917871-557c-41db-b038-a250d23ee07c -== APP == Bulk Subscriber got: "This is message #0" -== APP == Bulk Subscriber message has entry ID: df114819-0db9-4a04-b06b-d5844d3ff731 -== APP == Bulk Subscriber got: "This is message #1" -== APP == Bulk Subscriber received 2 messages. -== APP == Bulk Subscriber message has entry ID: 8161f1e2-caf0-446a-81f7-0b40e7350e19 -== APP == Bulk Subscriber got: "This is message #2" -== APP == Bulk Subscriber message has entry ID: 173fafa1-d187-4b2d-83bf-b4da00616a3a -== APP == Bulk Subscriber got: "This is message #3" -== APP == Bulk Subscriber received 2 messages. -== APP == Bulk Subscriber message has entry ID: 94f89996-155d-4b52-8a8c-c268662ff3a2 -== APP == Bulk Subscriber got: "This is message #4" -== APP == Bulk Subscriber message has entry ID: 497c47a4-e4f7-4aeb-abde-099068dea30c -== APP == Bulk Subscriber got: "This is message #5" -== APP == Bulk Subscriber received 1 messages. -== APP == Bulk Subscriber message has entry ID: 892fb1ae-b027-457a-860e-52b9c3219270 -== APP == Bulk Subscriber got: "This is message #6" -== APP == Bulk Subscriber received 2 messages. -== APP == Bulk Subscriber message has entry ID: 95abf8cc-e033-483d-9a55-e0491bd97930 -== APP == Bulk Subscriber got: "This is message #7" -== APP == Bulk Subscriber message has entry ID: eaf75a31-335e-4c1a-b19a-6aa1710f625a -== APP == Bulk Subscriber got: "This is message #8" -== APP == Bulk Subscriber received 1 messages. -== APP == Bulk Subscriber message has entry ID: 9836ef69-6d3c-4738-ba99-1d0ce68ec06b -== APP == Bulk Subscriber got: "This is message #9" +Bulk Subscriber received 2 messages. +Bulk Subscriber message has entry ID: 0c917871-557c-41db-b038-a250d23ee07c +Bulk Subscriber got: "This is message #0" +Bulk Subscriber message has entry ID: df114819-0db9-4a04-b06b-d5844d3ff731 +Bulk Subscriber got: "This is message #1" +Bulk Subscriber received 2 messages. +Bulk Subscriber message has entry ID: 8161f1e2-caf0-446a-81f7-0b40e7350e19 +Bulk Subscriber got: "This is message #2" +Bulk Subscriber message has entry ID: 173fafa1-d187-4b2d-83bf-b4da00616a3a +Bulk Subscriber got: "This is message #3" +Bulk Subscriber received 2 messages. +Bulk Subscriber message has entry ID: 94f89996-155d-4b52-8a8c-c268662ff3a2 +Bulk Subscriber got: "This is message #4" +Bulk Subscriber message has entry ID: 497c47a4-e4f7-4aeb-abde-099068dea30c +Bulk Subscriber got: "This is message #5" +Bulk Subscriber received 1 messages. +Bulk Subscriber message has entry ID: 892fb1ae-b027-457a-860e-52b9c3219270 +Bulk Subscriber got: "This is message #6" +Bulk Subscriber received 2 messages. +Bulk Subscriber message has entry ID: 95abf8cc-e033-483d-9a55-e0491bd97930 +Bulk Subscriber got: "This is message #7" +Bulk Subscriber message has entry ID: eaf75a31-335e-4c1a-b19a-6aa1710f625a +Bulk Subscriber got: "This is message #8" +Bulk Subscriber received 1 messages. +Bulk Subscriber message has entry ID: 9836ef69-6d3c-4738-ba99-1d0ce68ec06b +Bulk Subscriber got: "This is message #9" ``` >The order of the events that are published are not guaranteed if use redis. @@ -830,8 +830,8 @@ If you would like to add a tracing span as a parent of the span created by Dapr, diff --git a/examples/src/main/java/io/dapr/examples/pubsub/stream/README.md b/examples/src/main/java/io/dapr/examples/pubsub/stream/README.md index c31607f753..d24f441085 100644 --- a/examples/src/main/java/io/dapr/examples/pubsub/stream/README.md +++ b/examples/src/main/java/io/dapr/examples/pubsub/stream/README.md @@ -119,8 +119,8 @@ Execute the following command to run the raw data Subscriber example: @@ -268,20 +268,20 @@ dapr run --resources-path ./components/state --app-id query-state-example -H 360 Once running, the QuerySaveState example should print the output as follows: ```txt -== APP == Waiting for Dapr sidecar ... -== APP == Dapr sidecar is ready. -== APP == Insert key: 1, data: Listing{propertyType='apartment', id=1000, city='Seattle', state='WA'} -== APP == Insert key: 2, data: Listing{propertyType='row-house', id=1002, city='Seattle', state='WA'} -== APP == Insert key: 3, data: Listing{propertyType='apartment', id=1003, city='Portland', state='OR'} -== APP == Insert key: 4, data: Listing{propertyType='apartment', id=1001, city='Portland', state='OR'} -== APP == Found 3 items. -== APP == Key: 3 -== APP == Data: Listing{propertyType='apartment', id=1003, city='Portland', state='OR'} -== APP == Key: 4 -== APP == Data: Listing{propertyType='apartment', id=1001, city='Portland', state='OR'} -== APP == Key: 1 -== APP == Data: Listing{propertyType='apartment', id=1000, city='Seattle', state='WA'} -== APP == Done +Waiting for Dapr sidecar ... +Dapr sidecar is ready. +Insert key: 1, data: Listing{propertyType='apartment', id=1000, city='Seattle', state='WA'} +Insert key: 2, data: Listing{propertyType='row-house', id=1002, city='Seattle', state='WA'} +Insert key: 3, data: Listing{propertyType='apartment', id=1003, city='Portland', state='OR'} +Insert key: 4, data: Listing{propertyType='apartment', id=1001, city='Portland', state='OR'} +Found 3 items. +Key: 3 +Data: Listing{propertyType='apartment', id=1003, city='Portland', state='OR'} +Key: 4 +Data: Listing{propertyType='apartment', id=1001, city='Portland', state='OR'} +Key: 1 +Data: Listing{propertyType='apartment', id=1000, city='Seattle', state='WA'} +Done ``` Note that the output is in descending order of the field `id`, and all the `propertyType` field values are the same `apartment`. diff --git a/examples/src/main/java/io/dapr/examples/secrets/README.md b/examples/src/main/java/io/dapr/examples/secrets/README.md index fc609d7f92..f13b7b961c 100644 --- a/examples/src/main/java/io/dapr/examples/secrets/README.md +++ b/examples/src/main/java/io/dapr/examples/secrets/README.md @@ -116,8 +116,8 @@ Execute the following script in order to run the example: @@ -131,8 +131,8 @@ dapr run --resources-path ./components/secrets --app-id secrets1 -- java -jar ta Once running, the program should print the output as follows: ``` -== APP == {"redisPassword":"root123"} -== APP == {"randomKey":"value"} +{"redisPassword":"root123"} +{"randomKey":"value"} ``` To close the app either press `CTRL+C` or run @@ -169,8 +169,8 @@ Execute the following script in order to run this example with additional secret @@ -184,8 +184,8 @@ dapr run --resources-path ./components/secrets --config ./src/main/java/io/dapr/ Once running, the program should print the output as follows: ``` -== APP == {"redisPassword":"root123"} -== APP == PERMISSION_DENIED: access denied by policy to get "randomKey" from "localSecretStore" +{"redisPassword":"root123"} +PERMISSION_DENIED: access denied by policy to get "randomKey" from "localSecretStore" ``` To close the app either press `CTRL+C` or run diff --git a/examples/src/main/java/io/dapr/examples/state/README.md b/examples/src/main/java/io/dapr/examples/state/README.md index 6038db8fb2..3bfb23315d 100644 --- a/examples/src/main/java/io/dapr/examples/state/README.md +++ b/examples/src/main/java/io/dapr/examples/state/README.md @@ -156,23 +156,23 @@ The Dapr client is also within a try-with-resource block to properly close the c @@ -187,23 +187,23 @@ dapr run --resources-path ./components/state --app-id state-example -- java -jar Once running, the StateClient should print the output as follows: ```txt -== APP == Waiting for Dapr sidecar ... -== APP == Dapr sidecar is ready. -== APP == Saving class with message: my message -== APP == Retrieved class message from state: my message -== APP == Updating previous state and adding another state 'test state'... -== APP == Saving updated class with message: my message updated -== APP == Retrieved messages using bulk get: -== APP == StateKeyValue{key='myKey', value=my message updated, etag='2', metadata={'{}'}, error='null', options={'null'}} -== APP == StateKeyValue{key='myKey2', value=test message, etag='1', metadata={'{}'}, error='null', options={'null'}} -== APP == Deleting states... -== APP == Verify delete key request is aborted if an etag different from stored is passed. -== APP == Expected failure. ABORTED: failed deleting state with key myKey: possible etag mismatch. error from state store: ERR Error running script (call to f_9b5da7354cb61e2ca9faff50f6c43b81c73c0b94): @user_script:1: user_script:1: failed to delete Tailmad-Fang||myKey -== APP == Trying to delete again with correct etag. -== APP == Trying to retrieve deleted states: -== APP == StateKeyValue{key='myKey', value=null, etag='null', metadata={'{}'}, error='null', options={'null'}} -== APP == StateKeyValue{key='myKey2', value=null, etag='null', metadata={'{}'}, error='null', options={'null'}} -== APP == Done +Waiting for Dapr sidecar ... +Dapr sidecar is ready. +Saving class with message: my message +Retrieved class message from state: my message +Updating previous state and adding another state 'test state'... +Saving updated class with message: my message updated +Retrieved messages using bulk get: +StateKeyValue{key='myKey', value=my message updated, etag='2', metadata={'{}'}, error='null', options={'null'}} +StateKeyValue{key='myKey2', value=test message, etag='1', metadata={'{}'}, error='null', options={'null'}} +Deleting states... +Verify delete key request is aborted if an etag different from stored is passed. +Expected failure. ABORTED: failed deleting state with key myKey: possible etag mismatch. error from state store: ERR Error running script (call to f_9b5da7354cb61e2ca9faff50f6c43b81c73c0b94): @user_script:1: user_script:1: failed to delete Tailmad-Fang||myKey +Trying to delete again with correct etag. +Trying to retrieve deleted states: +StateKeyValue{key='myKey', value=null, etag='null', metadata={'{}'}, error='null', options={'null'}} +StateKeyValue{key='myKey2', value=null, etag='null', metadata={'{}'}, error='null', options={'null'}} +Done ``` ### Cleanup diff --git a/examples/src/main/java/io/dapr/examples/tracing/README.md b/examples/src/main/java/io/dapr/examples/tracing/README.md index 707dae01a7..b6c149d959 100644 --- a/examples/src/main/java/io/dapr/examples/tracing/README.md +++ b/examples/src/main/java/io/dapr/examples/tracing/README.md @@ -283,7 +283,7 @@ Execute the follow script in order to run the InvokeClient example, passing two @@ -179,17 +179,17 @@ dapr stop --app-id chainingworker Now you can see the worker logs showing the acitvity is invoked in sequnce and the status of each activity: ```text -== APP == 2023-11-07 11:03:14,178 {HH:mm:ss.SSS} [main] INFO io.dapr.workflows.WorkflowContext - Starting Workflow: io.dapr.examples.workflows.chain.DemoChainWorkflow -== APP == 2023-11-07 11:03:14,229 {HH:mm:ss.SSS} [main] INFO i.d.e.w.chain.ToUpperCaseActivity - Starting Activity: io.dapr.examples.workflows.chain.ToUpperCaseActivity -== APP == 2023-11-07 11:03:14,235 {HH:mm:ss.SSS} [main] INFO i.d.e.w.chain.ToUpperCaseActivity - Message Received from input: Tokyo -== APP == 2023-11-07 11:03:14,235 {HH:mm:ss.SSS} [main] INFO i.d.e.w.chain.ToUpperCaseActivity - Sending message to output: TOKYO -== APP == 2023-11-07 11:03:14,266 {HH:mm:ss.SSS} [main] INFO i.d.e.w.chain.ToUpperCaseActivity - Starting Activity: io.dapr.examples.workflows.chain.ToUpperCaseActivity -== APP == 2023-11-07 11:03:14,267 {HH:mm:ss.SSS} [main] INFO i.d.e.w.chain.ToUpperCaseActivity - Message Received from input: London -== APP == 2023-11-07 11:03:14,267 {HH:mm:ss.SSS} [main] INFO i.d.e.w.chain.ToUpperCaseActivity - Sending message to output: LONDON -== APP == 2023-11-07 11:03:14,282 {HH:mm:ss.SSS} [main] INFO i.d.e.w.chain.ToUpperCaseActivity - Starting Activity: io.dapr.examples.workflows.chain.ToUpperCaseActivity -== APP == 2023-11-07 11:03:14,282 {HH:mm:ss.SSS} [main] INFO i.d.e.w.chain.ToUpperCaseActivity - Message Received from input: Seattle -== APP == 2023-11-07 11:03:14,283 {HH:mm:ss.SSS} [main] INFO i.d.e.w.chain.ToUpperCaseActivity - Sending message to output: SEATTLE -== APP == 2023-11-07 11:03:14,298 {HH:mm:ss.SSS} [main] INFO io.dapr.workflows.WorkflowContext - Workflow finished with result: TOKYO, LONDON, SEATTLE +2023-11-07 11:03:14,178 {HH:mm:ss.SSS} [main] INFO io.dapr.workflows.WorkflowContext - Starting Workflow: io.dapr.examples.workflows.chain.DemoChainWorkflow +2023-11-07 11:03:14,229 {HH:mm:ss.SSS} [main] INFO i.d.e.w.chain.ToUpperCaseActivity - Starting Activity: io.dapr.examples.workflows.chain.ToUpperCaseActivity +2023-11-07 11:03:14,235 {HH:mm:ss.SSS} [main] INFO i.d.e.w.chain.ToUpperCaseActivity - Message Received from input: Tokyo +2023-11-07 11:03:14,235 {HH:mm:ss.SSS} [main] INFO i.d.e.w.chain.ToUpperCaseActivity - Sending message to output: TOKYO +2023-11-07 11:03:14,266 {HH:mm:ss.SSS} [main] INFO i.d.e.w.chain.ToUpperCaseActivity - Starting Activity: io.dapr.examples.workflows.chain.ToUpperCaseActivity +2023-11-07 11:03:14,267 {HH:mm:ss.SSS} [main] INFO i.d.e.w.chain.ToUpperCaseActivity - Message Received from input: London +2023-11-07 11:03:14,267 {HH:mm:ss.SSS} [main] INFO i.d.e.w.chain.ToUpperCaseActivity - Sending message to output: LONDON +2023-11-07 11:03:14,282 {HH:mm:ss.SSS} [main] INFO i.d.e.w.chain.ToUpperCaseActivity - Starting Activity: io.dapr.examples.workflows.chain.ToUpperCaseActivity +2023-11-07 11:03:14,282 {HH:mm:ss.SSS} [main] INFO i.d.e.w.chain.ToUpperCaseActivity - Message Received from input: Seattle +2023-11-07 11:03:14,283 {HH:mm:ss.SSS} [main] INFO i.d.e.w.chain.ToUpperCaseActivity - Sending message to output: SEATTLE +2023-11-07 11:03:14,298 {HH:mm:ss.SSS} [main] INFO io.dapr.workflows.WorkflowContext - Workflow finished with result: TOKYO, LONDON, SEATTLE ``` and the client logs showing the workflow is started and finished with expected result: ```text @@ -291,23 +291,23 @@ dapr stop --app-id faninoutworker Now you can see the logs from worker: ```text -== APP == 2023-11-07 14:52:03,075 {HH:mm:ss.SSS} [main] INFO io.dapr.workflows.WorkflowContext - Starting Workflow: io.dapr.examples.workflows.faninout.DemoFanInOutWorkflow -== APP == 2023-11-07 14:52:03,144 {HH:mm:ss.SSS} [main] INFO i.d.e.w.faninout.CountWordsActivity - Starting Activity: io.dapr.examples.workflows.faninout.CountWordsActivity -== APP == 2023-11-07 14:52:03,147 {HH:mm:ss.SSS} [main] INFO i.d.e.w.faninout.CountWordsActivity - Activity returned: 2. -== APP == 2023-11-07 14:52:03,148 {HH:mm:ss.SSS} [main] INFO i.d.e.w.faninout.CountWordsActivity - Activity finished -== APP == 2023-11-07 14:52:03,152 {HH:mm:ss.SSS} [main] INFO i.d.e.w.faninout.CountWordsActivity - Starting Activity: io.dapr.examples.workflows.faninout.CountWordsActivity -== APP == 2023-11-07 14:52:03,152 {HH:mm:ss.SSS} [main] INFO i.d.e.w.faninout.CountWordsActivity - Activity returned: 9. -== APP == 2023-11-07 14:52:03,152 {HH:mm:ss.SSS} [main] INFO i.d.e.w.faninout.CountWordsActivity - Activity finished -== APP == 2023-11-07 14:52:03,167 {HH:mm:ss.SSS} [main] INFO i.d.e.w.faninout.CountWordsActivity - Starting Activity: io.dapr.examples.workflows.faninout.CountWordsActivity -== APP == 2023-11-07 14:52:03,167 {HH:mm:ss.SSS} [main] INFO i.d.e.w.faninout.CountWordsActivity - Activity returned: 21. -== APP == 2023-11-07 14:52:03,167 {HH:mm:ss.SSS} [main] INFO i.d.e.w.faninout.CountWordsActivity - Activity finished -== APP == 2023-11-07 14:52:03,170 {HH:mm:ss.SSS} [main] INFO i.d.e.w.faninout.CountWordsActivity - Starting Activity: io.dapr.examples.workflows.faninout.CountWordsActivity -== APP == 2023-11-07 14:52:03,170 {HH:mm:ss.SSS} [main] INFO i.d.e.w.faninout.CountWordsActivity - Activity returned: 17. -== APP == 2023-11-07 14:52:03,170 {HH:mm:ss.SSS} [main] INFO i.d.e.w.faninout.CountWordsActivity - Activity finished -== APP == 2023-11-07 14:52:03,173 {HH:mm:ss.SSS} [main] INFO i.d.e.w.faninout.CountWordsActivity - Starting Activity: io.dapr.examples.workflows.faninout.CountWordsActivity -== APP == 2023-11-07 14:52:03,173 {HH:mm:ss.SSS} [main] INFO i.d.e.w.faninout.CountWordsActivity - Activity returned: 11. -== APP == 2023-11-07 14:52:03,174 {HH:mm:ss.SSS} [main] INFO i.d.e.w.faninout.CountWordsActivity - Activity finished -== APP == 2023-11-07 14:52:03,212 {HH:mm:ss.SSS} [main] INFO io.dapr.workflows.WorkflowContext - Workflow finished with result: 60 +2023-11-07 14:52:03,075 {HH:mm:ss.SSS} [main] INFO io.dapr.workflows.WorkflowContext - Starting Workflow: io.dapr.examples.workflows.faninout.DemoFanInOutWorkflow +2023-11-07 14:52:03,144 {HH:mm:ss.SSS} [main] INFO i.d.e.w.faninout.CountWordsActivity - Starting Activity: io.dapr.examples.workflows.faninout.CountWordsActivity +2023-11-07 14:52:03,147 {HH:mm:ss.SSS} [main] INFO i.d.e.w.faninout.CountWordsActivity - Activity returned: 2. +2023-11-07 14:52:03,148 {HH:mm:ss.SSS} [main] INFO i.d.e.w.faninout.CountWordsActivity - Activity finished +2023-11-07 14:52:03,152 {HH:mm:ss.SSS} [main] INFO i.d.e.w.faninout.CountWordsActivity - Starting Activity: io.dapr.examples.workflows.faninout.CountWordsActivity +2023-11-07 14:52:03,152 {HH:mm:ss.SSS} [main] INFO i.d.e.w.faninout.CountWordsActivity - Activity returned: 9. +2023-11-07 14:52:03,152 {HH:mm:ss.SSS} [main] INFO i.d.e.w.faninout.CountWordsActivity - Activity finished +2023-11-07 14:52:03,167 {HH:mm:ss.SSS} [main] INFO i.d.e.w.faninout.CountWordsActivity - Starting Activity: io.dapr.examples.workflows.faninout.CountWordsActivity +2023-11-07 14:52:03,167 {HH:mm:ss.SSS} [main] INFO i.d.e.w.faninout.CountWordsActivity - Activity returned: 21. +2023-11-07 14:52:03,167 {HH:mm:ss.SSS} [main] INFO i.d.e.w.faninout.CountWordsActivity - Activity finished +2023-11-07 14:52:03,170 {HH:mm:ss.SSS} [main] INFO i.d.e.w.faninout.CountWordsActivity - Starting Activity: io.dapr.examples.workflows.faninout.CountWordsActivity +2023-11-07 14:52:03,170 {HH:mm:ss.SSS} [main] INFO i.d.e.w.faninout.CountWordsActivity - Activity returned: 17. +2023-11-07 14:52:03,170 {HH:mm:ss.SSS} [main] INFO i.d.e.w.faninout.CountWordsActivity - Activity finished +2023-11-07 14:52:03,173 {HH:mm:ss.SSS} [main] INFO i.d.e.w.faninout.CountWordsActivity - Starting Activity: io.dapr.examples.workflows.faninout.CountWordsActivity +2023-11-07 14:52:03,173 {HH:mm:ss.SSS} [main] INFO i.d.e.w.faninout.CountWordsActivity - Activity returned: 11. +2023-11-07 14:52:03,174 {HH:mm:ss.SSS} [main] INFO i.d.e.w.faninout.CountWordsActivity - Activity finished +2023-11-07 14:52:03,212 {HH:mm:ss.SSS} [main] INFO io.dapr.workflows.WorkflowContext - Workflow finished with result: 60 ``` and the client: @@ -378,26 +378,26 @@ java -jar target/dapr-java-sdk-examples-exec.jar io.dapr.examples.workflows.cont You will see the logs from worker showing the `CleanUpActivity` is invoked every 10 seconds after previous one is finished: ```text -== APP == 2023-11-07 14:44:42,004 {HH:mm:ss.SSS} [main] INFO io.dapr.workflows.WorkflowContext - Starting Workflow: io.dapr.examples.workflows.continueasnew.DemoContinueAsNewWorkflow -== APP == 2023-11-07 14:44:42,004 {HH:mm:ss.SSS} [main] INFO io.dapr.workflows.WorkflowContext - call CleanUpActivity to do the clean up -== APP == 2023-11-07 14:44:42,009 {HH:mm:ss.SSS} [main] INFO i.d.e.w.c.CleanUpActivity - Starting Activity: io.dapr.examples.workflows.continueasnew.CleanUpActivity -== APP == 2023-11-07 14:44:42,009 {HH:mm:ss.SSS} [main] INFO i.d.e.w.c.CleanUpActivity - start clean up work, it may take few seconds to finish... -== APP == 2023-11-07 14:44:47,026 {HH:mm:ss.SSS} [main] INFO io.dapr.workflows.WorkflowContext - Starting Workflow: io.dapr.examples.workflows.continueasnew.DemoContinueAsNewWorkflow -== APP == 2023-11-07 14:44:47,026 {HH:mm:ss.SSS} [main] INFO io.dapr.workflows.WorkflowContext - call CleanUpActivity to do the clean up -== APP == 2023-11-07 14:44:47,030 {HH:mm:ss.SSS} [main] INFO io.dapr.workflows.WorkflowContext - CleanUpActivity finished -== APP == 2023-11-07 14:44:47,030 {HH:mm:ss.SSS} [main] INFO io.dapr.workflows.WorkflowContext - wait 10 seconds for next clean up -== APP == 2023-11-07 14:44:47,033 {HH:mm:ss.SSS} [main] INFO i.d.e.w.c.CleanUpActivity - Starting Activity: io.dapr.examples.workflows.continueasnew.CleanUpActivity -== APP == 2023-11-07 14:44:47,033 {HH:mm:ss.SSS} [main] INFO i.d.e.w.c.CleanUpActivity - start clean up work, it may take few seconds to finish... -== APP == 2023-11-07 14:44:52,053 {HH:mm:ss.SSS} [main] INFO io.dapr.workflows.WorkflowContext - CleanUpActivity finished -== APP == 2023-11-07 14:44:52,053 {HH:mm:ss.SSS} [main] INFO io.dapr.workflows.WorkflowContext - wait 10 seconds for next clean up -== APP == 2023-11-07 14:44:57,006 {HH:mm:ss.SSS} [main] INFO io.dapr.workflows.WorkflowContext - Starting Workflow: io.dapr.examples.workflows.continueasnew.DemoContinueAsNewWorkflow -== APP == 2023-11-07 14:44:57,006 {HH:mm:ss.SSS} [main] INFO io.dapr.workflows.WorkflowContext - call CleanUpActivity to do the clean up -== APP == 2023-11-07 14:44:57,012 {HH:mm:ss.SSS} [main] INFO i.d.e.w.c.CleanUpActivity - Starting Activity: io.dapr.examples.workflows.continueasnew.CleanUpActivity -== APP == 2023-11-07 14:44:57,012 {HH:mm:ss.SSS} [main] INFO i.d.e.w.c.CleanUpActivity - start clean up work, it may take few seconds to finish... -== APP == 2023-11-07 14:45:02,017 {HH:mm:ss.SSS} [main] INFO io.dapr.workflows.WorkflowContext - Starting Workflow: io.dapr.examples.workflows.continueasnew.DemoContinueAsNewWorkflow -== APP == 2023-11-07 14:45:02,020 {HH:mm:ss.SSS} [main] INFO io.dapr.workflows.WorkflowContext - call CleanUpActivity to do the clean up -== APP == 2023-11-07 14:45:02,021 {HH:mm:ss.SSS} [main] INFO io.dapr.workflows.WorkflowContext - CleanUpActivity finished -== APP == 2023-11-07 14:45:02,021 {HH:mm:ss.SSS} [main] INFO io.dapr.workflows.WorkflowContext - wait 10 seconds for next clean up +2023-11-07 14:44:42,004 {HH:mm:ss.SSS} [main] INFO io.dapr.workflows.WorkflowContext - Starting Workflow: io.dapr.examples.workflows.continueasnew.DemoContinueAsNewWorkflow +2023-11-07 14:44:42,004 {HH:mm:ss.SSS} [main] INFO io.dapr.workflows.WorkflowContext - call CleanUpActivity to do the clean up +2023-11-07 14:44:42,009 {HH:mm:ss.SSS} [main] INFO i.d.e.w.c.CleanUpActivity - Starting Activity: io.dapr.examples.workflows.continueasnew.CleanUpActivity +2023-11-07 14:44:42,009 {HH:mm:ss.SSS} [main] INFO i.d.e.w.c.CleanUpActivity - start clean up work, it may take few seconds to finish... +2023-11-07 14:44:47,026 {HH:mm:ss.SSS} [main] INFO io.dapr.workflows.WorkflowContext - Starting Workflow: io.dapr.examples.workflows.continueasnew.DemoContinueAsNewWorkflow +2023-11-07 14:44:47,026 {HH:mm:ss.SSS} [main] INFO io.dapr.workflows.WorkflowContext - call CleanUpActivity to do the clean up +2023-11-07 14:44:47,030 {HH:mm:ss.SSS} [main] INFO io.dapr.workflows.WorkflowContext - CleanUpActivity finished +2023-11-07 14:44:47,030 {HH:mm:ss.SSS} [main] INFO io.dapr.workflows.WorkflowContext - wait 10 seconds for next clean up +2023-11-07 14:44:47,033 {HH:mm:ss.SSS} [main] INFO i.d.e.w.c.CleanUpActivity - Starting Activity: io.dapr.examples.workflows.continueasnew.CleanUpActivity +2023-11-07 14:44:47,033 {HH:mm:ss.SSS} [main] INFO i.d.e.w.c.CleanUpActivity - start clean up work, it may take few seconds to finish... +2023-11-07 14:44:52,053 {HH:mm:ss.SSS} [main] INFO io.dapr.workflows.WorkflowContext - CleanUpActivity finished +2023-11-07 14:44:52,053 {HH:mm:ss.SSS} [main] INFO io.dapr.workflows.WorkflowContext - wait 10 seconds for next clean up +2023-11-07 14:44:57,006 {HH:mm:ss.SSS} [main] INFO io.dapr.workflows.WorkflowContext - Starting Workflow: io.dapr.examples.workflows.continueasnew.DemoContinueAsNewWorkflow +2023-11-07 14:44:57,006 {HH:mm:ss.SSS} [main] INFO io.dapr.workflows.WorkflowContext - call CleanUpActivity to do the clean up +2023-11-07 14:44:57,012 {HH:mm:ss.SSS} [main] INFO i.d.e.w.c.CleanUpActivity - Starting Activity: io.dapr.examples.workflows.continueasnew.CleanUpActivity +2023-11-07 14:44:57,012 {HH:mm:ss.SSS} [main] INFO i.d.e.w.c.CleanUpActivity - start clean up work, it may take few seconds to finish... +2023-11-07 14:45:02,017 {HH:mm:ss.SSS} [main] INFO io.dapr.workflows.WorkflowContext - Starting Workflow: io.dapr.examples.workflows.continueasnew.DemoContinueAsNewWorkflow +2023-11-07 14:45:02,020 {HH:mm:ss.SSS} [main] INFO io.dapr.workflows.WorkflowContext - call CleanUpActivity to do the clean up +2023-11-07 14:45:02,021 {HH:mm:ss.SSS} [main] INFO io.dapr.workflows.WorkflowContext - CleanUpActivity finished +2023-11-07 14:45:02,021 {HH:mm:ss.SSS} [main] INFO io.dapr.workflows.WorkflowContext - wait 10 seconds for next clean up ... ``` @@ -450,12 +450,12 @@ java -jar target/dapr-java-sdk-examples-exec.jar io.dapr.examples.workflows.exte The worker logs: ```text -== APP == 2023-11-07 16:01:23,279 {HH:mm:ss.SSS} [main] INFO io.dapr.workflows.WorkflowContext - Starting Workflow: io.dapr.examples.workflows.externalevent.DemoExternalEventWorkflow -== APP == 2023-11-07 16:01:23,279 {HH:mm:ss.SSS} [main] INFO io.dapr.workflows.WorkflowContext - Waiting for approval... -== APP == 2023-11-07 16:01:23,324 {HH:mm:ss.SSS} [main] INFO io.dapr.workflows.WorkflowContext - approval granted - do the approved action -== APP == 2023-11-07 16:01:23,348 {HH:mm:ss.SSS} [main] INFO i.d.e.w.e.ApproveActivity - Starting Activity: io.dapr.examples.workflows.externalevent.ApproveActivity -== APP == 2023-11-07 16:01:23,348 {HH:mm:ss.SSS} [main] INFO i.d.e.w.e.ApproveActivity - Running approval activity... -== APP == 2023-11-07 16:01:28,410 {HH:mm:ss.SSS} [main] INFO io.dapr.workflows.WorkflowContext - approval-activity finished +2023-11-07 16:01:23,279 {HH:mm:ss.SSS} [main] INFO io.dapr.workflows.WorkflowContext - Starting Workflow: io.dapr.examples.workflows.externalevent.DemoExternalEventWorkflow +2023-11-07 16:01:23,279 {HH:mm:ss.SSS} [main] INFO io.dapr.workflows.WorkflowContext - Waiting for approval... +2023-11-07 16:01:23,324 {HH:mm:ss.SSS} [main] INFO io.dapr.workflows.WorkflowContext - approval granted - do the approved action +2023-11-07 16:01:23,348 {HH:mm:ss.SSS} [main] INFO i.d.e.w.e.ApproveActivity - Starting Activity: io.dapr.examples.workflows.externalevent.ApproveActivity +2023-11-07 16:01:23,348 {HH:mm:ss.SSS} [main] INFO i.d.e.w.e.ApproveActivity - Running approval activity... +2023-11-07 16:01:28,410 {HH:mm:ss.SSS} [main] INFO io.dapr.workflows.WorkflowContext - approval-activity finished ``` The client log: @@ -543,16 +543,16 @@ java -jar target/dapr-java-sdk-examples-exec.jar io.dapr.examples.workflows.chil The log from worker: ```text -== APP == 2023-11-07 20:08:52,521 {HH:mm:ss.SSS} [main] INFO io.dapr.workflows.WorkflowContext - Starting Workflow: io.dapr.examples.workflows.childworkflow.DemoWorkflow -== APP == 2023-11-07 20:08:52,523 {HH:mm:ss.SSS} [main] INFO io.dapr.workflows.WorkflowContext - calling childworkflow with input: Hello Dapr Workflow! -== APP == 2023-11-07 20:08:52,561 {HH:mm:ss.SSS} [main] INFO io.dapr.workflows.WorkflowContext - Starting ChildWorkflow: io.dapr.examples.workflows.childworkflow.DemoChildWorkflow -== APP == 2023-11-07 20:08:52,566 {HH:mm:ss.SSS} [main] INFO io.dapr.workflows.WorkflowContext - ChildWorkflow received input: Hello Dapr Workflow! -== APP == 2023-11-07 20:08:52,566 {HH:mm:ss.SSS} [main] INFO io.dapr.workflows.WorkflowContext - ChildWorkflow is calling Activity: io.dapr.examples.workflows.childworkflow.ReverseActivity -== APP == 2023-11-07 20:08:52,576 {HH:mm:ss.SSS} [main] INFO i.d.e.w.childworkflow.ReverseActivity - Starting Activity: io.dapr.examples.workflows.childworkflow.ReverseActivity -== APP == 2023-11-07 20:08:52,577 {HH:mm:ss.SSS} [main] INFO i.d.e.w.childworkflow.ReverseActivity - Message Received from input: Hello Dapr Workflow! -== APP == 2023-11-07 20:08:52,577 {HH:mm:ss.SSS} [main] INFO i.d.e.w.childworkflow.ReverseActivity - Sending message to output: !wolfkroW rpaD olleH -== APP == 2023-11-07 20:08:52,596 {HH:mm:ss.SSS} [main] INFO io.dapr.workflows.WorkflowContext - ChildWorkflow finished with: !wolfkroW rpaD olleH -== APP == 2023-11-07 20:08:52,611 {HH:mm:ss.SSS} [main] INFO io.dapr.workflows.WorkflowContext - childworkflow finished with: !wolfkroW rpaD olleH +2023-11-07 20:08:52,521 {HH:mm:ss.SSS} [main] INFO io.dapr.workflows.WorkflowContext - Starting Workflow: io.dapr.examples.workflows.childworkflow.DemoWorkflow +2023-11-07 20:08:52,523 {HH:mm:ss.SSS} [main] INFO io.dapr.workflows.WorkflowContext - calling childworkflow with input: Hello Dapr Workflow! +2023-11-07 20:08:52,561 {HH:mm:ss.SSS} [main] INFO io.dapr.workflows.WorkflowContext - Starting ChildWorkflow: io.dapr.examples.workflows.childworkflow.DemoChildWorkflow +2023-11-07 20:08:52,566 {HH:mm:ss.SSS} [main] INFO io.dapr.workflows.WorkflowContext - ChildWorkflow received input: Hello Dapr Workflow! +2023-11-07 20:08:52,566 {HH:mm:ss.SSS} [main] INFO io.dapr.workflows.WorkflowContext - ChildWorkflow is calling Activity: io.dapr.examples.workflows.childworkflow.ReverseActivity +2023-11-07 20:08:52,576 {HH:mm:ss.SSS} [main] INFO i.d.e.w.childworkflow.ReverseActivity - Starting Activity: io.dapr.examples.workflows.childworkflow.ReverseActivity +2023-11-07 20:08:52,577 {HH:mm:ss.SSS} [main] INFO i.d.e.w.childworkflow.ReverseActivity - Message Received from input: Hello Dapr Workflow! +2023-11-07 20:08:52,577 {HH:mm:ss.SSS} [main] INFO i.d.e.w.childworkflow.ReverseActivity - Sending message to output: !wolfkroW rpaD olleH +2023-11-07 20:08:52,596 {HH:mm:ss.SSS} [main] INFO io.dapr.workflows.WorkflowContext - ChildWorkflow finished with: !wolfkroW rpaD olleH +2023-11-07 20:08:52,611 {HH:mm:ss.SSS} [main] INFO io.dapr.workflows.WorkflowContext - childworkflow finished with: !wolfkroW rpaD olleH ``` The log from client: @@ -884,12 +884,12 @@ dapr stop --app-id suspendresumeworker The worker logs: ```text -== APP == 2023-11-07 16:01:23,279 {HH:mm:ss.SSS} [main] INFO io.dapr.workflows.WorkflowContext - Starting Workflow: io.dapr.examples.workflows.suspendresume.DemoExternalEventWorkflow -== APP == 2023-11-07 16:01:23,279 {HH:mm:ss.SSS} [main] INFO io.dapr.workflows.WorkflowContext - Waiting for approval... -== APP == 2023-11-07 16:01:23,324 {HH:mm:ss.SSS} [main] INFO io.dapr.workflows.WorkflowContext - approval granted - do the approved action -== APP == 2023-11-07 16:01:23,348 {HH:mm:ss.SSS} [main] INFO i.d.e.w.e.ApproveActivity - Starting Activity: io.dapr.examples.workflows.externalevent.ApproveActivity -== APP == 2023-11-07 16:01:23,348 {HH:mm:ss.SSS} [main] INFO i.d.e.w.e.ApproveActivity - Running approval activity... -== APP == 2023-11-07 16:01:28,410 {HH:mm:ss.SSS} [main] INFO io.dapr.workflows.WorkflowContext - approval-activity finished +2023-11-07 16:01:23,279 {HH:mm:ss.SSS} [main] INFO io.dapr.workflows.WorkflowContext - Starting Workflow: io.dapr.examples.workflows.suspendresume.DemoExternalEventWorkflow +2023-11-07 16:01:23,279 {HH:mm:ss.SSS} [main] INFO io.dapr.workflows.WorkflowContext - Waiting for approval... +2023-11-07 16:01:23,324 {HH:mm:ss.SSS} [main] INFO io.dapr.workflows.WorkflowContext - approval granted - do the approved action +2023-11-07 16:01:23,348 {HH:mm:ss.SSS} [main] INFO i.d.e.w.e.ApproveActivity - Starting Activity: io.dapr.examples.workflows.externalevent.ApproveActivity +2023-11-07 16:01:23,348 {HH:mm:ss.SSS} [main] INFO i.d.e.w.e.ApproveActivity - Running approval activity... +2023-11-07 16:01:28,410 {HH:mm:ss.SSS} [main] INFO io.dapr.workflows.WorkflowContext - approval-activity finished ``` The client log: diff --git a/pom.xml b/pom.xml index 28ccd99e4f..34a68774a1 100644 --- a/pom.xml +++ b/pom.xml @@ -16,7 +16,7 @@ UTF-8 1.79.0 3.25.5 - https://raw.githubusercontent.com/dapr/dapr/v1.17.0-rc.10/dapr/proto + https://raw.githubusercontent.com/dapr/dapr/v1.17.0/dapr/proto https://raw.githubusercontent.com/dapr/durabletask-protobuf/main/protos/orchestrator_service.proto 1.17.0-rc-4 1.7.1 diff --git a/spring-boot-examples/kubernetes/README.md b/spring-boot-examples/kubernetes/README.md index 47d27a2d46..6b74f48c8d 100644 --- a/spring-boot-examples/kubernetes/README.md +++ b/spring-boot-examples/kubernetes/README.md @@ -30,7 +30,7 @@ Once you have the cluster up and running you can install Dapr: helm repo add dapr https://dapr.github.io/helm-charts/ helm repo update helm upgrade --install dapr dapr/dapr \ ---version=1.17.0-rc.10 \ +--version=1.17.0 \ --namespace dapr-system \ --create-namespace \ --wait diff --git a/testcontainers-dapr/src/main/java/io/dapr/testcontainers/DaprContainerConstants.java b/testcontainers-dapr/src/main/java/io/dapr/testcontainers/DaprContainerConstants.java index 5cc3703d5e..85e379a51e 100644 --- a/testcontainers-dapr/src/main/java/io/dapr/testcontainers/DaprContainerConstants.java +++ b/testcontainers-dapr/src/main/java/io/dapr/testcontainers/DaprContainerConstants.java @@ -14,7 +14,7 @@ package io.dapr.testcontainers; public interface DaprContainerConstants { - String DAPR_VERSION = "1.17.0-rc.10"; + String DAPR_VERSION = "1.17.0"; String DAPR_WORKFLOWS_DASHBOARD_VERSION = "0.0.1"; String DAPR_RUNTIME_IMAGE_TAG = "daprio/daprd:" + DAPR_VERSION; String DAPR_PLACEMENT_IMAGE_TAG = "daprio/placement:" + DAPR_VERSION;