Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension


Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
2 changes: 1 addition & 1 deletion java/basics/build.gradle.kts
Original file line number Diff line number Diff line change
Expand Up @@ -7,7 +7,7 @@ repositories {
mavenCentral()
}

val restateVersion = "2.4.0"
val restateVersion = "2.4.2"

dependencies {
annotationProcessor("dev.restate:sdk-api-gen:$restateVersion")
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -11,7 +11,7 @@ repositories {
mavenCentral()
}

val restateVersion = "2.4.0"
val restateVersion = "2.4.2"

dependencies {
// Restate SDK
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -10,7 +10,7 @@ repositories {
mavenCentral()
}

val restateVersion = "2.4.0"
val restateVersion = "2.4.2"

dependencies {
// Kafka
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -7,7 +7,7 @@ repositories {
mavenCentral()
}

val restateVersion = "2.4.0"
val restateVersion = "2.4.2"

dependencies {
annotationProcessor("dev.restate:sdk-api-gen:$restateVersion")
Expand Down
2 changes: 1 addition & 1 deletion java/end-to-end-applications/workflow-interpreter/pom.xml
Original file line number Diff line number Diff line change
Expand Up @@ -30,7 +30,7 @@
<java.version>17</java.version>
<!-- Override Netty version to make sure we bring in the latest with MadeYourReset CVE fix-->
<netty.version>4.1.124.Final</netty.version>
<restate.version>2.4.0</restate.version>
<restate.version>2.4.2</restate.version>
</properties>
<dependencies>
<dependency>
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -6,7 +6,7 @@ repositories {
mavenCentral()
}

val restateVersion = "2.4.0"
val restateVersion = "2.4.2"

dependencies {
// Annotation processor
Expand Down
2 changes: 1 addition & 1 deletion java/integrations/java-spring/build.gradle.kts
Original file line number Diff line number Diff line change
Expand Up @@ -13,7 +13,7 @@ repositories {
mavenCentral()
}

val restateVersion = "2.4.0"
val restateVersion = "2.4.2"

dependencies {
implementation("org.springframework.boot:spring-boot-starter")
Expand Down
2 changes: 1 addition & 1 deletion java/patterns-use-cases/build.gradle.kts
Original file line number Diff line number Diff line change
Expand Up @@ -8,7 +8,7 @@ repositories {
mavenCentral()
}

val restateVersion = "2.4.0"
val restateVersion = "2.4.2"

dependencies {
annotationProcessor("dev.restate:sdk-api-gen:$restateVersion")
Expand Down
35 changes: 26 additions & 9 deletions java/templates/java-gradle/.claude/CLAUDE.md
Original file line number Diff line number Diff line change
Expand Up @@ -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
Expand Down Expand Up @@ -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)
Expand Down Expand Up @@ -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();
Expand Down Expand Up @@ -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
35 changes: 26 additions & 9 deletions java/templates/java-gradle/.cursor/rules/AGENTS.md
Original file line number Diff line number Diff line change
Expand Up @@ -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
Expand Down Expand Up @@ -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)
Expand Down Expand Up @@ -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();
Expand Down Expand Up @@ -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
2 changes: 1 addition & 1 deletion java/templates/java-gradle/build.gradle.kts
Original file line number Diff line number Diff line change
Expand Up @@ -7,7 +7,7 @@ repositories {
mavenCentral()
}

val restateVersion = "2.4.0"
val restateVersion = "2.4.2"

dependencies {
annotationProcessor("dev.restate:sdk-api-gen:$restateVersion")
Expand Down
35 changes: 26 additions & 9 deletions java/templates/java-maven-quarkus/.claude/CLAUDE.md
Original file line number Diff line number Diff line change
Expand Up @@ -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
Expand Down Expand Up @@ -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)
Expand Down Expand Up @@ -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();
Expand Down Expand Up @@ -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
35 changes: 26 additions & 9 deletions java/templates/java-maven-quarkus/.cursor/rules/AGENTS.md
Original file line number Diff line number Diff line change
Expand Up @@ -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
Expand Down Expand Up @@ -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)
Expand Down Expand Up @@ -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();
Expand Down Expand Up @@ -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
2 changes: 1 addition & 1 deletion java/templates/java-maven-quarkus/pom.xml
Original file line number Diff line number Diff line change
Expand Up @@ -15,7 +15,7 @@
<quarkus.platform.version>3.15.1</quarkus.platform.version>
<skipITs>true</skipITs>
<surefire-plugin.version>3.3.1</surefire-plugin.version>
<restate.version>2.4.0</restate.version>
<restate.version>2.4.2</restate.version>
</properties>

<dependencyManagement>
Expand Down
Loading