diff --git a/java/basics/build.gradle.kts b/java/basics/build.gradle.kts index 4babeae0..defdea6b 100644 --- a/java/basics/build.gradle.kts +++ b/java/basics/build.gradle.kts @@ -7,7 +7,7 @@ repositories { mavenCentral() } -val restateVersion = "2.4.0" +val restateVersion = "2.4.2" dependencies { annotationProcessor("dev.restate:sdk-api-gen:$restateVersion") diff --git a/java/end-to-end-applications/food-ordering/app/restate-app/build.gradle.kts b/java/end-to-end-applications/food-ordering/app/restate-app/build.gradle.kts index 4f16970f..c6192fea 100644 --- a/java/end-to-end-applications/food-ordering/app/restate-app/build.gradle.kts +++ b/java/end-to-end-applications/food-ordering/app/restate-app/build.gradle.kts @@ -11,7 +11,7 @@ repositories { mavenCentral() } -val restateVersion = "2.4.0" +val restateVersion = "2.4.2" dependencies { // Restate SDK diff --git a/java/end-to-end-applications/food-ordering/app/restaurant/build.gradle.kts b/java/end-to-end-applications/food-ordering/app/restaurant/build.gradle.kts index eb3c99f5..abc01d8f 100644 --- a/java/end-to-end-applications/food-ordering/app/restaurant/build.gradle.kts +++ b/java/end-to-end-applications/food-ordering/app/restaurant/build.gradle.kts @@ -10,7 +10,7 @@ repositories { mavenCentral() } -val restateVersion = "2.4.0" +val restateVersion = "2.4.2" dependencies { // Kafka diff --git a/java/end-to-end-applications/subway-fare-calculator/build.gradle.kts b/java/end-to-end-applications/subway-fare-calculator/build.gradle.kts index 4ba49d5b..387deb31 100644 --- a/java/end-to-end-applications/subway-fare-calculator/build.gradle.kts +++ b/java/end-to-end-applications/subway-fare-calculator/build.gradle.kts @@ -7,7 +7,7 @@ repositories { mavenCentral() } -val restateVersion = "2.4.0" +val restateVersion = "2.4.2" dependencies { annotationProcessor("dev.restate:sdk-api-gen:$restateVersion") diff --git a/java/end-to-end-applications/workflow-interpreter/pom.xml b/java/end-to-end-applications/workflow-interpreter/pom.xml index 00644e6f..58260bff 100644 --- a/java/end-to-end-applications/workflow-interpreter/pom.xml +++ b/java/end-to-end-applications/workflow-interpreter/pom.xml @@ -30,7 +30,7 @@ 17 4.1.124.Final - 2.4.0 + 2.4.2 diff --git a/java/integrations/java-gradle-lambda-cdk/lambda/build.gradle.kts b/java/integrations/java-gradle-lambda-cdk/lambda/build.gradle.kts index bde8e6a2..07d15b49 100644 --- a/java/integrations/java-gradle-lambda-cdk/lambda/build.gradle.kts +++ b/java/integrations/java-gradle-lambda-cdk/lambda/build.gradle.kts @@ -6,7 +6,7 @@ repositories { mavenCentral() } -val restateVersion = "2.4.0" +val restateVersion = "2.4.2" dependencies { // Annotation processor diff --git a/java/integrations/java-spring/build.gradle.kts b/java/integrations/java-spring/build.gradle.kts index fd1b603c..507ade98 100644 --- a/java/integrations/java-spring/build.gradle.kts +++ b/java/integrations/java-spring/build.gradle.kts @@ -13,7 +13,7 @@ repositories { mavenCentral() } -val restateVersion = "2.4.0" +val restateVersion = "2.4.2" dependencies { implementation("org.springframework.boot:spring-boot-starter") diff --git a/java/patterns-use-cases/build.gradle.kts b/java/patterns-use-cases/build.gradle.kts index c3b88bc0..a7d1a977 100644 --- a/java/patterns-use-cases/build.gradle.kts +++ b/java/patterns-use-cases/build.gradle.kts @@ -8,7 +8,7 @@ repositories { mavenCentral() } -val restateVersion = "2.4.0" +val restateVersion = "2.4.2" dependencies { annotationProcessor("dev.restate:sdk-api-gen:$restateVersion") diff --git a/java/templates/java-gradle/.claude/CLAUDE.md b/java/templates/java-gradle/.claude/CLAUDE.md index 9f70a669..a7454322 100644 --- a/java/templates/java-gradle/.claude/CLAUDE.md +++ b/java/templates/java-gradle/.claude/CLAUDE.md @@ -144,15 +144,25 @@ Call a service without using the generated client, but just String names. ```java {"CODE_LOAD::java/src/main/java/develop/agentsmd/Actions.java#generic_calls"} theme={null} // Generic service call Target target = Target.service("MyService", "myHandler"); -String response = ctx.call(Request.of(target, TypeTag.of(String.class), TypeTag.of(String.class), request)).await(); +String response = + ctx.call(Request.of(target, TypeTag.of(String.class), TypeTag.of(String.class), request)) + .await(); // Generic object call Target objectTarget = Target.virtualObject("MyObject", "object-key", "myHandler"); -String objResponse = ctx.call(Request.of(objectTarget, TypeTag.of(String.class), TypeTag.of(String.class), request)).await(); +String objResponse = + ctx.call( + Request.of( + objectTarget, TypeTag.of(String.class), TypeTag.of(String.class), request)) + .await(); // Generic workflow call Target workflowTarget = Target.workflow("MyWorkflow", "wf-id", "run"); -String wfResponse = ctx.call(Request.of(workflowTarget, TypeTag.of(String.class), TypeTag.of(String.class), request)).await(); +String wfResponse = + ctx.call( + Request.of( + workflowTarget, TypeTag.of(String.class), TypeTag.of(String.class), request)) + .await(); ``` #### One-Way Messages @@ -215,7 +225,9 @@ ctx.sleep(Duration.ofSeconds(30)); // Schedule delayed call (different from sleep + send) Target target = Target.service("MyService", "myHandler"); -ctx.send(Request.of(target, TypeTag.of(String.class), TypeTag.of(String.class), "Hi"), Duration.ofHours(5)); +ctx.send( + Request.of(target, TypeTag.of(String.class), TypeTag.of(String.class), "Hi"), + Duration.ofHours(5)); ``` ### Awakeables (External Events) @@ -278,9 +290,9 @@ int indexCompleted = DurableFuture.any(call1, call2).await(); ```java {"CODE_LOAD::java/src/main/java/develop/agentsmd/Actions.java#cancel"} theme={null} var handle = - MyServiceClient.fromContext(ctx) - .send() - .myHandler(request, req -> req.idempotencyKey("abc123")); + MyServiceClient.fromContext(ctx) + .send() + .myHandler(request, req -> req.idempotencyKey("abc123")); var response = handle.attach().await(); // Cancel invocation handle.cancel(); @@ -386,6 +398,11 @@ MyServiceClient.fromClient(restateClient).send().myHandler("Hi", Duration.ofSeco // With idempotency key MyObjectClient.fromClient(restateClient, "Mary") - .send() - .myHandler("Hi", opt -> opt.idempotencyKey("abc")); + .send() + .myHandler("Hi", opt -> opt.idempotencyKey("abc")); ``` + + +--- + +> To find navigation and other pages in this documentation, fetch the llms.txt file at: https://docs.restate.dev/llms.txt \ No newline at end of file diff --git a/java/templates/java-gradle/.cursor/rules/AGENTS.md b/java/templates/java-gradle/.cursor/rules/AGENTS.md index 9f70a669..a7454322 100644 --- a/java/templates/java-gradle/.cursor/rules/AGENTS.md +++ b/java/templates/java-gradle/.cursor/rules/AGENTS.md @@ -144,15 +144,25 @@ Call a service without using the generated client, but just String names. ```java {"CODE_LOAD::java/src/main/java/develop/agentsmd/Actions.java#generic_calls"} theme={null} // Generic service call Target target = Target.service("MyService", "myHandler"); -String response = ctx.call(Request.of(target, TypeTag.of(String.class), TypeTag.of(String.class), request)).await(); +String response = + ctx.call(Request.of(target, TypeTag.of(String.class), TypeTag.of(String.class), request)) + .await(); // Generic object call Target objectTarget = Target.virtualObject("MyObject", "object-key", "myHandler"); -String objResponse = ctx.call(Request.of(objectTarget, TypeTag.of(String.class), TypeTag.of(String.class), request)).await(); +String objResponse = + ctx.call( + Request.of( + objectTarget, TypeTag.of(String.class), TypeTag.of(String.class), request)) + .await(); // Generic workflow call Target workflowTarget = Target.workflow("MyWorkflow", "wf-id", "run"); -String wfResponse = ctx.call(Request.of(workflowTarget, TypeTag.of(String.class), TypeTag.of(String.class), request)).await(); +String wfResponse = + ctx.call( + Request.of( + workflowTarget, TypeTag.of(String.class), TypeTag.of(String.class), request)) + .await(); ``` #### One-Way Messages @@ -215,7 +225,9 @@ ctx.sleep(Duration.ofSeconds(30)); // Schedule delayed call (different from sleep + send) Target target = Target.service("MyService", "myHandler"); -ctx.send(Request.of(target, TypeTag.of(String.class), TypeTag.of(String.class), "Hi"), Duration.ofHours(5)); +ctx.send( + Request.of(target, TypeTag.of(String.class), TypeTag.of(String.class), "Hi"), + Duration.ofHours(5)); ``` ### Awakeables (External Events) @@ -278,9 +290,9 @@ int indexCompleted = DurableFuture.any(call1, call2).await(); ```java {"CODE_LOAD::java/src/main/java/develop/agentsmd/Actions.java#cancel"} theme={null} var handle = - MyServiceClient.fromContext(ctx) - .send() - .myHandler(request, req -> req.idempotencyKey("abc123")); + MyServiceClient.fromContext(ctx) + .send() + .myHandler(request, req -> req.idempotencyKey("abc123")); var response = handle.attach().await(); // Cancel invocation handle.cancel(); @@ -386,6 +398,11 @@ MyServiceClient.fromClient(restateClient).send().myHandler("Hi", Duration.ofSeco // With idempotency key MyObjectClient.fromClient(restateClient, "Mary") - .send() - .myHandler("Hi", opt -> opt.idempotencyKey("abc")); + .send() + .myHandler("Hi", opt -> opt.idempotencyKey("abc")); ``` + + +--- + +> To find navigation and other pages in this documentation, fetch the llms.txt file at: https://docs.restate.dev/llms.txt \ No newline at end of file diff --git a/java/templates/java-gradle/build.gradle.kts b/java/templates/java-gradle/build.gradle.kts index 62a907f3..d4e77af1 100644 --- a/java/templates/java-gradle/build.gradle.kts +++ b/java/templates/java-gradle/build.gradle.kts @@ -7,7 +7,7 @@ repositories { mavenCentral() } -val restateVersion = "2.4.0" +val restateVersion = "2.4.2" dependencies { annotationProcessor("dev.restate:sdk-api-gen:$restateVersion") diff --git a/java/templates/java-maven-quarkus/.claude/CLAUDE.md b/java/templates/java-maven-quarkus/.claude/CLAUDE.md index 9f70a669..a7454322 100644 --- a/java/templates/java-maven-quarkus/.claude/CLAUDE.md +++ b/java/templates/java-maven-quarkus/.claude/CLAUDE.md @@ -144,15 +144,25 @@ Call a service without using the generated client, but just String names. ```java {"CODE_LOAD::java/src/main/java/develop/agentsmd/Actions.java#generic_calls"} theme={null} // Generic service call Target target = Target.service("MyService", "myHandler"); -String response = ctx.call(Request.of(target, TypeTag.of(String.class), TypeTag.of(String.class), request)).await(); +String response = + ctx.call(Request.of(target, TypeTag.of(String.class), TypeTag.of(String.class), request)) + .await(); // Generic object call Target objectTarget = Target.virtualObject("MyObject", "object-key", "myHandler"); -String objResponse = ctx.call(Request.of(objectTarget, TypeTag.of(String.class), TypeTag.of(String.class), request)).await(); +String objResponse = + ctx.call( + Request.of( + objectTarget, TypeTag.of(String.class), TypeTag.of(String.class), request)) + .await(); // Generic workflow call Target workflowTarget = Target.workflow("MyWorkflow", "wf-id", "run"); -String wfResponse = ctx.call(Request.of(workflowTarget, TypeTag.of(String.class), TypeTag.of(String.class), request)).await(); +String wfResponse = + ctx.call( + Request.of( + workflowTarget, TypeTag.of(String.class), TypeTag.of(String.class), request)) + .await(); ``` #### One-Way Messages @@ -215,7 +225,9 @@ ctx.sleep(Duration.ofSeconds(30)); // Schedule delayed call (different from sleep + send) Target target = Target.service("MyService", "myHandler"); -ctx.send(Request.of(target, TypeTag.of(String.class), TypeTag.of(String.class), "Hi"), Duration.ofHours(5)); +ctx.send( + Request.of(target, TypeTag.of(String.class), TypeTag.of(String.class), "Hi"), + Duration.ofHours(5)); ``` ### Awakeables (External Events) @@ -278,9 +290,9 @@ int indexCompleted = DurableFuture.any(call1, call2).await(); ```java {"CODE_LOAD::java/src/main/java/develop/agentsmd/Actions.java#cancel"} theme={null} var handle = - MyServiceClient.fromContext(ctx) - .send() - .myHandler(request, req -> req.idempotencyKey("abc123")); + MyServiceClient.fromContext(ctx) + .send() + .myHandler(request, req -> req.idempotencyKey("abc123")); var response = handle.attach().await(); // Cancel invocation handle.cancel(); @@ -386,6 +398,11 @@ MyServiceClient.fromClient(restateClient).send().myHandler("Hi", Duration.ofSeco // With idempotency key MyObjectClient.fromClient(restateClient, "Mary") - .send() - .myHandler("Hi", opt -> opt.idempotencyKey("abc")); + .send() + .myHandler("Hi", opt -> opt.idempotencyKey("abc")); ``` + + +--- + +> To find navigation and other pages in this documentation, fetch the llms.txt file at: https://docs.restate.dev/llms.txt \ No newline at end of file diff --git a/java/templates/java-maven-quarkus/.cursor/rules/AGENTS.md b/java/templates/java-maven-quarkus/.cursor/rules/AGENTS.md index 9f70a669..a7454322 100644 --- a/java/templates/java-maven-quarkus/.cursor/rules/AGENTS.md +++ b/java/templates/java-maven-quarkus/.cursor/rules/AGENTS.md @@ -144,15 +144,25 @@ Call a service without using the generated client, but just String names. ```java {"CODE_LOAD::java/src/main/java/develop/agentsmd/Actions.java#generic_calls"} theme={null} // Generic service call Target target = Target.service("MyService", "myHandler"); -String response = ctx.call(Request.of(target, TypeTag.of(String.class), TypeTag.of(String.class), request)).await(); +String response = + ctx.call(Request.of(target, TypeTag.of(String.class), TypeTag.of(String.class), request)) + .await(); // Generic object call Target objectTarget = Target.virtualObject("MyObject", "object-key", "myHandler"); -String objResponse = ctx.call(Request.of(objectTarget, TypeTag.of(String.class), TypeTag.of(String.class), request)).await(); +String objResponse = + ctx.call( + Request.of( + objectTarget, TypeTag.of(String.class), TypeTag.of(String.class), request)) + .await(); // Generic workflow call Target workflowTarget = Target.workflow("MyWorkflow", "wf-id", "run"); -String wfResponse = ctx.call(Request.of(workflowTarget, TypeTag.of(String.class), TypeTag.of(String.class), request)).await(); +String wfResponse = + ctx.call( + Request.of( + workflowTarget, TypeTag.of(String.class), TypeTag.of(String.class), request)) + .await(); ``` #### One-Way Messages @@ -215,7 +225,9 @@ ctx.sleep(Duration.ofSeconds(30)); // Schedule delayed call (different from sleep + send) Target target = Target.service("MyService", "myHandler"); -ctx.send(Request.of(target, TypeTag.of(String.class), TypeTag.of(String.class), "Hi"), Duration.ofHours(5)); +ctx.send( + Request.of(target, TypeTag.of(String.class), TypeTag.of(String.class), "Hi"), + Duration.ofHours(5)); ``` ### Awakeables (External Events) @@ -278,9 +290,9 @@ int indexCompleted = DurableFuture.any(call1, call2).await(); ```java {"CODE_LOAD::java/src/main/java/develop/agentsmd/Actions.java#cancel"} theme={null} var handle = - MyServiceClient.fromContext(ctx) - .send() - .myHandler(request, req -> req.idempotencyKey("abc123")); + MyServiceClient.fromContext(ctx) + .send() + .myHandler(request, req -> req.idempotencyKey("abc123")); var response = handle.attach().await(); // Cancel invocation handle.cancel(); @@ -386,6 +398,11 @@ MyServiceClient.fromClient(restateClient).send().myHandler("Hi", Duration.ofSeco // With idempotency key MyObjectClient.fromClient(restateClient, "Mary") - .send() - .myHandler("Hi", opt -> opt.idempotencyKey("abc")); + .send() + .myHandler("Hi", opt -> opt.idempotencyKey("abc")); ``` + + +--- + +> To find navigation and other pages in this documentation, fetch the llms.txt file at: https://docs.restate.dev/llms.txt \ No newline at end of file diff --git a/java/templates/java-maven-quarkus/pom.xml b/java/templates/java-maven-quarkus/pom.xml index ad65c2a2..93c5d862 100644 --- a/java/templates/java-maven-quarkus/pom.xml +++ b/java/templates/java-maven-quarkus/pom.xml @@ -15,7 +15,7 @@ 3.15.1 true 3.3.1 - 2.4.0 + 2.4.2 diff --git a/java/templates/java-maven-spring-boot/.claude/CLAUDE.md b/java/templates/java-maven-spring-boot/.claude/CLAUDE.md index 9f70a669..a7454322 100644 --- a/java/templates/java-maven-spring-boot/.claude/CLAUDE.md +++ b/java/templates/java-maven-spring-boot/.claude/CLAUDE.md @@ -144,15 +144,25 @@ Call a service without using the generated client, but just String names. ```java {"CODE_LOAD::java/src/main/java/develop/agentsmd/Actions.java#generic_calls"} theme={null} // Generic service call Target target = Target.service("MyService", "myHandler"); -String response = ctx.call(Request.of(target, TypeTag.of(String.class), TypeTag.of(String.class), request)).await(); +String response = + ctx.call(Request.of(target, TypeTag.of(String.class), TypeTag.of(String.class), request)) + .await(); // Generic object call Target objectTarget = Target.virtualObject("MyObject", "object-key", "myHandler"); -String objResponse = ctx.call(Request.of(objectTarget, TypeTag.of(String.class), TypeTag.of(String.class), request)).await(); +String objResponse = + ctx.call( + Request.of( + objectTarget, TypeTag.of(String.class), TypeTag.of(String.class), request)) + .await(); // Generic workflow call Target workflowTarget = Target.workflow("MyWorkflow", "wf-id", "run"); -String wfResponse = ctx.call(Request.of(workflowTarget, TypeTag.of(String.class), TypeTag.of(String.class), request)).await(); +String wfResponse = + ctx.call( + Request.of( + workflowTarget, TypeTag.of(String.class), TypeTag.of(String.class), request)) + .await(); ``` #### One-Way Messages @@ -215,7 +225,9 @@ ctx.sleep(Duration.ofSeconds(30)); // Schedule delayed call (different from sleep + send) Target target = Target.service("MyService", "myHandler"); -ctx.send(Request.of(target, TypeTag.of(String.class), TypeTag.of(String.class), "Hi"), Duration.ofHours(5)); +ctx.send( + Request.of(target, TypeTag.of(String.class), TypeTag.of(String.class), "Hi"), + Duration.ofHours(5)); ``` ### Awakeables (External Events) @@ -278,9 +290,9 @@ int indexCompleted = DurableFuture.any(call1, call2).await(); ```java {"CODE_LOAD::java/src/main/java/develop/agentsmd/Actions.java#cancel"} theme={null} var handle = - MyServiceClient.fromContext(ctx) - .send() - .myHandler(request, req -> req.idempotencyKey("abc123")); + MyServiceClient.fromContext(ctx) + .send() + .myHandler(request, req -> req.idempotencyKey("abc123")); var response = handle.attach().await(); // Cancel invocation handle.cancel(); @@ -386,6 +398,11 @@ MyServiceClient.fromClient(restateClient).send().myHandler("Hi", Duration.ofSeco // With idempotency key MyObjectClient.fromClient(restateClient, "Mary") - .send() - .myHandler("Hi", opt -> opt.idempotencyKey("abc")); + .send() + .myHandler("Hi", opt -> opt.idempotencyKey("abc")); ``` + + +--- + +> To find navigation and other pages in this documentation, fetch the llms.txt file at: https://docs.restate.dev/llms.txt \ No newline at end of file diff --git a/java/templates/java-maven-spring-boot/.cursor/rules/AGENTS.md b/java/templates/java-maven-spring-boot/.cursor/rules/AGENTS.md index 9f70a669..a7454322 100644 --- a/java/templates/java-maven-spring-boot/.cursor/rules/AGENTS.md +++ b/java/templates/java-maven-spring-boot/.cursor/rules/AGENTS.md @@ -144,15 +144,25 @@ Call a service without using the generated client, but just String names. ```java {"CODE_LOAD::java/src/main/java/develop/agentsmd/Actions.java#generic_calls"} theme={null} // Generic service call Target target = Target.service("MyService", "myHandler"); -String response = ctx.call(Request.of(target, TypeTag.of(String.class), TypeTag.of(String.class), request)).await(); +String response = + ctx.call(Request.of(target, TypeTag.of(String.class), TypeTag.of(String.class), request)) + .await(); // Generic object call Target objectTarget = Target.virtualObject("MyObject", "object-key", "myHandler"); -String objResponse = ctx.call(Request.of(objectTarget, TypeTag.of(String.class), TypeTag.of(String.class), request)).await(); +String objResponse = + ctx.call( + Request.of( + objectTarget, TypeTag.of(String.class), TypeTag.of(String.class), request)) + .await(); // Generic workflow call Target workflowTarget = Target.workflow("MyWorkflow", "wf-id", "run"); -String wfResponse = ctx.call(Request.of(workflowTarget, TypeTag.of(String.class), TypeTag.of(String.class), request)).await(); +String wfResponse = + ctx.call( + Request.of( + workflowTarget, TypeTag.of(String.class), TypeTag.of(String.class), request)) + .await(); ``` #### One-Way Messages @@ -215,7 +225,9 @@ ctx.sleep(Duration.ofSeconds(30)); // Schedule delayed call (different from sleep + send) Target target = Target.service("MyService", "myHandler"); -ctx.send(Request.of(target, TypeTag.of(String.class), TypeTag.of(String.class), "Hi"), Duration.ofHours(5)); +ctx.send( + Request.of(target, TypeTag.of(String.class), TypeTag.of(String.class), "Hi"), + Duration.ofHours(5)); ``` ### Awakeables (External Events) @@ -278,9 +290,9 @@ int indexCompleted = DurableFuture.any(call1, call2).await(); ```java {"CODE_LOAD::java/src/main/java/develop/agentsmd/Actions.java#cancel"} theme={null} var handle = - MyServiceClient.fromContext(ctx) - .send() - .myHandler(request, req -> req.idempotencyKey("abc123")); + MyServiceClient.fromContext(ctx) + .send() + .myHandler(request, req -> req.idempotencyKey("abc123")); var response = handle.attach().await(); // Cancel invocation handle.cancel(); @@ -386,6 +398,11 @@ MyServiceClient.fromClient(restateClient).send().myHandler("Hi", Duration.ofSeco // With idempotency key MyObjectClient.fromClient(restateClient, "Mary") - .send() - .myHandler("Hi", opt -> opt.idempotencyKey("abc")); + .send() + .myHandler("Hi", opt -> opt.idempotencyKey("abc")); ``` + + +--- + +> To find navigation and other pages in this documentation, fetch the llms.txt file at: https://docs.restate.dev/llms.txt \ No newline at end of file diff --git a/java/templates/java-maven-spring-boot/pom.xml b/java/templates/java-maven-spring-boot/pom.xml index da5f4bae..722c1dac 100644 --- a/java/templates/java-maven-spring-boot/pom.xml +++ b/java/templates/java-maven-spring-boot/pom.xml @@ -28,7 +28,7 @@ 17 - 2.4.0 + 2.4.2 diff --git a/java/templates/java-maven/.claude/CLAUDE.md b/java/templates/java-maven/.claude/CLAUDE.md index 9f70a669..a7454322 100644 --- a/java/templates/java-maven/.claude/CLAUDE.md +++ b/java/templates/java-maven/.claude/CLAUDE.md @@ -144,15 +144,25 @@ Call a service without using the generated client, but just String names. ```java {"CODE_LOAD::java/src/main/java/develop/agentsmd/Actions.java#generic_calls"} theme={null} // Generic service call Target target = Target.service("MyService", "myHandler"); -String response = ctx.call(Request.of(target, TypeTag.of(String.class), TypeTag.of(String.class), request)).await(); +String response = + ctx.call(Request.of(target, TypeTag.of(String.class), TypeTag.of(String.class), request)) + .await(); // Generic object call Target objectTarget = Target.virtualObject("MyObject", "object-key", "myHandler"); -String objResponse = ctx.call(Request.of(objectTarget, TypeTag.of(String.class), TypeTag.of(String.class), request)).await(); +String objResponse = + ctx.call( + Request.of( + objectTarget, TypeTag.of(String.class), TypeTag.of(String.class), request)) + .await(); // Generic workflow call Target workflowTarget = Target.workflow("MyWorkflow", "wf-id", "run"); -String wfResponse = ctx.call(Request.of(workflowTarget, TypeTag.of(String.class), TypeTag.of(String.class), request)).await(); +String wfResponse = + ctx.call( + Request.of( + workflowTarget, TypeTag.of(String.class), TypeTag.of(String.class), request)) + .await(); ``` #### One-Way Messages @@ -215,7 +225,9 @@ ctx.sleep(Duration.ofSeconds(30)); // Schedule delayed call (different from sleep + send) Target target = Target.service("MyService", "myHandler"); -ctx.send(Request.of(target, TypeTag.of(String.class), TypeTag.of(String.class), "Hi"), Duration.ofHours(5)); +ctx.send( + Request.of(target, TypeTag.of(String.class), TypeTag.of(String.class), "Hi"), + Duration.ofHours(5)); ``` ### Awakeables (External Events) @@ -278,9 +290,9 @@ int indexCompleted = DurableFuture.any(call1, call2).await(); ```java {"CODE_LOAD::java/src/main/java/develop/agentsmd/Actions.java#cancel"} theme={null} var handle = - MyServiceClient.fromContext(ctx) - .send() - .myHandler(request, req -> req.idempotencyKey("abc123")); + MyServiceClient.fromContext(ctx) + .send() + .myHandler(request, req -> req.idempotencyKey("abc123")); var response = handle.attach().await(); // Cancel invocation handle.cancel(); @@ -386,6 +398,11 @@ MyServiceClient.fromClient(restateClient).send().myHandler("Hi", Duration.ofSeco // With idempotency key MyObjectClient.fromClient(restateClient, "Mary") - .send() - .myHandler("Hi", opt -> opt.idempotencyKey("abc")); + .send() + .myHandler("Hi", opt -> opt.idempotencyKey("abc")); ``` + + +--- + +> To find navigation and other pages in this documentation, fetch the llms.txt file at: https://docs.restate.dev/llms.txt \ No newline at end of file diff --git a/java/templates/java-maven/.cursor/rules/AGENTS.md b/java/templates/java-maven/.cursor/rules/AGENTS.md index 9f70a669..a7454322 100644 --- a/java/templates/java-maven/.cursor/rules/AGENTS.md +++ b/java/templates/java-maven/.cursor/rules/AGENTS.md @@ -144,15 +144,25 @@ Call a service without using the generated client, but just String names. ```java {"CODE_LOAD::java/src/main/java/develop/agentsmd/Actions.java#generic_calls"} theme={null} // Generic service call Target target = Target.service("MyService", "myHandler"); -String response = ctx.call(Request.of(target, TypeTag.of(String.class), TypeTag.of(String.class), request)).await(); +String response = + ctx.call(Request.of(target, TypeTag.of(String.class), TypeTag.of(String.class), request)) + .await(); // Generic object call Target objectTarget = Target.virtualObject("MyObject", "object-key", "myHandler"); -String objResponse = ctx.call(Request.of(objectTarget, TypeTag.of(String.class), TypeTag.of(String.class), request)).await(); +String objResponse = + ctx.call( + Request.of( + objectTarget, TypeTag.of(String.class), TypeTag.of(String.class), request)) + .await(); // Generic workflow call Target workflowTarget = Target.workflow("MyWorkflow", "wf-id", "run"); -String wfResponse = ctx.call(Request.of(workflowTarget, TypeTag.of(String.class), TypeTag.of(String.class), request)).await(); +String wfResponse = + ctx.call( + Request.of( + workflowTarget, TypeTag.of(String.class), TypeTag.of(String.class), request)) + .await(); ``` #### One-Way Messages @@ -215,7 +225,9 @@ ctx.sleep(Duration.ofSeconds(30)); // Schedule delayed call (different from sleep + send) Target target = Target.service("MyService", "myHandler"); -ctx.send(Request.of(target, TypeTag.of(String.class), TypeTag.of(String.class), "Hi"), Duration.ofHours(5)); +ctx.send( + Request.of(target, TypeTag.of(String.class), TypeTag.of(String.class), "Hi"), + Duration.ofHours(5)); ``` ### Awakeables (External Events) @@ -278,9 +290,9 @@ int indexCompleted = DurableFuture.any(call1, call2).await(); ```java {"CODE_LOAD::java/src/main/java/develop/agentsmd/Actions.java#cancel"} theme={null} var handle = - MyServiceClient.fromContext(ctx) - .send() - .myHandler(request, req -> req.idempotencyKey("abc123")); + MyServiceClient.fromContext(ctx) + .send() + .myHandler(request, req -> req.idempotencyKey("abc123")); var response = handle.attach().await(); // Cancel invocation handle.cancel(); @@ -386,6 +398,11 @@ MyServiceClient.fromClient(restateClient).send().myHandler("Hi", Duration.ofSeco // With idempotency key MyObjectClient.fromClient(restateClient, "Mary") - .send() - .myHandler("Hi", opt -> opt.idempotencyKey("abc")); + .send() + .myHandler("Hi", opt -> opt.idempotencyKey("abc")); ``` + + +--- + +> To find navigation and other pages in this documentation, fetch the llms.txt file at: https://docs.restate.dev/llms.txt \ No newline at end of file diff --git a/java/templates/java-maven/pom.xml b/java/templates/java-maven/pom.xml index dd68a844..0b82a3ac 100644 --- a/java/templates/java-maven/pom.xml +++ b/java/templates/java-maven/pom.xml @@ -15,7 +15,7 @@ UTF-8 17 17 - 2.4.0 + 2.4.2 diff --git a/java/tutorials/tour-of-orchestration-java/build.gradle.kts b/java/tutorials/tour-of-orchestration-java/build.gradle.kts index 5dfeaf6a..bcdb0ca8 100644 --- a/java/tutorials/tour-of-orchestration-java/build.gradle.kts +++ b/java/tutorials/tour-of-orchestration-java/build.gradle.kts @@ -8,7 +8,7 @@ repositories { mavenCentral() } -val restateVersion = "2.4.0" +val restateVersion = "2.4.2" dependencies { annotationProcessor("dev.restate:sdk-api-gen:$restateVersion") diff --git a/java/tutorials/tour-of-workflows-java/build.gradle.kts b/java/tutorials/tour-of-workflows-java/build.gradle.kts index 512dd666..8cf8c95c 100644 --- a/java/tutorials/tour-of-workflows-java/build.gradle.kts +++ b/java/tutorials/tour-of-workflows-java/build.gradle.kts @@ -8,7 +8,7 @@ repositories { mavenCentral() } -val restateVersion = "2.4.0" +val restateVersion = "2.4.2" dependencies { annotationProcessor("dev.restate:sdk-api-gen:$restateVersion") diff --git a/kotlin/basics/build.gradle.kts b/kotlin/basics/build.gradle.kts index df1f332b..2622bf54 100644 --- a/kotlin/basics/build.gradle.kts +++ b/kotlin/basics/build.gradle.kts @@ -9,7 +9,7 @@ repositories { mavenCentral() } -val restateVersion = "2.4.0" +val restateVersion = "2.4.2" dependencies { // Annotation processor diff --git a/kotlin/end-to-end-applications/food-ordering/app/restate-app/build.gradle.kts b/kotlin/end-to-end-applications/food-ordering/app/restate-app/build.gradle.kts index 417cf903..588a9783 100644 --- a/kotlin/end-to-end-applications/food-ordering/app/restate-app/build.gradle.kts +++ b/kotlin/end-to-end-applications/food-ordering/app/restate-app/build.gradle.kts @@ -6,7 +6,7 @@ plugins { repositories { mavenCentral() } -val restateVersion = "2.4.0" +val restateVersion = "2.4.2" dependencies { // Restate SDK diff --git a/kotlin/end-to-end-applications/food-ordering/app/restaurant/build.gradle.kts b/kotlin/end-to-end-applications/food-ordering/app/restaurant/build.gradle.kts index 0236b24a..ada51bc4 100644 --- a/kotlin/end-to-end-applications/food-ordering/app/restaurant/build.gradle.kts +++ b/kotlin/end-to-end-applications/food-ordering/app/restaurant/build.gradle.kts @@ -7,7 +7,7 @@ repositories { mavenCentral() } -val restateVersion = "2.4.0" +val restateVersion = "2.4.2" dependencies { // Kafka diff --git a/kotlin/end-to-end-applications/kmp-android-todo-app/server/build.gradle.kts b/kotlin/end-to-end-applications/kmp-android-todo-app/server/build.gradle.kts index 71d578a7..1e167f38 100644 --- a/kotlin/end-to-end-applications/kmp-android-todo-app/server/build.gradle.kts +++ b/kotlin/end-to-end-applications/kmp-android-todo-app/server/build.gradle.kts @@ -8,7 +8,7 @@ plugins { group = "dev.restate.examples.noteapp" version = "1.0.0" -val restateVersion = "2.4.0" +val restateVersion = "2.4.2" kotlin { jvmToolchain(17) diff --git a/kotlin/integrations/kotlin-gradle-lambda-cdk/lambda/build.gradle.kts b/kotlin/integrations/kotlin-gradle-lambda-cdk/lambda/build.gradle.kts index b41b1873..79de4cf0 100644 --- a/kotlin/integrations/kotlin-gradle-lambda-cdk/lambda/build.gradle.kts +++ b/kotlin/integrations/kotlin-gradle-lambda-cdk/lambda/build.gradle.kts @@ -10,7 +10,7 @@ repositories { mavenCentral() } -val restateVersion = "2.4.0" +val restateVersion = "2.4.2" dependencies { // Annotation processor diff --git a/kotlin/patterns-use-cases/build.gradle.kts b/kotlin/patterns-use-cases/build.gradle.kts index b4074421..8da2b80b 100644 --- a/kotlin/patterns-use-cases/build.gradle.kts +++ b/kotlin/patterns-use-cases/build.gradle.kts @@ -8,7 +8,7 @@ plugins { repositories { mavenCentral() } -val restateVersion = "2.4.0" +val restateVersion = "2.4.2" dependencies { // Annotation processor diff --git a/kotlin/templates/kotlin-gradle-spring-boot/build.gradle.kts b/kotlin/templates/kotlin-gradle-spring-boot/build.gradle.kts index 257347ac..1f373287 100644 --- a/kotlin/templates/kotlin-gradle-spring-boot/build.gradle.kts +++ b/kotlin/templates/kotlin-gradle-spring-boot/build.gradle.kts @@ -21,7 +21,7 @@ repositories { mavenCentral() } -val restateVersion = "2.4.0" +val restateVersion = "2.4.2" dependencies { // Annotation processor diff --git a/kotlin/templates/kotlin-gradle/build.gradle.kts b/kotlin/templates/kotlin-gradle/build.gradle.kts index fefd1c63..24e5a9dc 100644 --- a/kotlin/templates/kotlin-gradle/build.gradle.kts +++ b/kotlin/templates/kotlin-gradle/build.gradle.kts @@ -9,7 +9,7 @@ repositories { mavenCentral() } -val restateVersion = "2.4.0" +val restateVersion = "2.4.2" dependencies { // Annotation processor