From 0a8fdc67bb5bb849f2a52705318d3feefc4d11e2 Mon Sep 17 00:00:00 2001 From: fuzi1996 Date: Wed, 14 Jan 2026 21:04:08 +0800 Subject: [PATCH 1/2] fix compile error --- .../org/springaicommunity/claude/agent/examples/HelloWorld.java | 1 + pom.xml | 1 + 2 files changed, 2 insertions(+) diff --git a/examples/hello-world/src/main/java/org/springaicommunity/claude/agent/examples/HelloWorld.java b/examples/hello-world/src/main/java/org/springaicommunity/claude/agent/examples/HelloWorld.java index 48812633..28c9b0e6 100644 --- a/examples/hello-world/src/main/java/org/springaicommunity/claude/agent/examples/HelloWorld.java +++ b/examples/hello-world/src/main/java/org/springaicommunity/claude/agent/examples/HelloWorld.java @@ -115,6 +115,7 @@ public static void main(String[] args) { .build(); asyncClient.connect("Explain recursion in 2 sentences.") + .messages() .thenMany(asyncClient.receiveResponse()) .filter(msg -> msg instanceof AssistantMessage) .flatMap(msg -> ((AssistantMessage) msg).getTextContent().map(reactor.core.publisher.Mono::just) diff --git a/pom.xml b/pom.xml index 82763cce..a8985b02 100644 --- a/pom.xml +++ b/pom.xml @@ -238,6 +238,7 @@ org.apache.maven.plugins maven-source-plugin ${maven-source-plugin.version} + false generate-sources From 04bf6a5e541164555a1a524c246855c9dc841033 Mon Sep 17 00:00:00 2001 From: fuzi1996 Date: Wed, 14 Jan 2026 21:28:59 +0800 Subject: [PATCH 2/2] fix connect error --- .../claude/agent/examples/email/service/ClaudeService.java | 2 +- examples/excel-demo/README.md | 2 +- .../claude/agent/examples/excel/service/ClaudeService.java | 4 ++-- 3 files changed, 4 insertions(+), 4 deletions(-) diff --git a/examples/email-agent/src/main/java/org/springaicommunity/claude/agent/examples/email/service/ClaudeService.java b/examples/email-agent/src/main/java/org/springaicommunity/claude/agent/examples/email/service/ClaudeService.java index 377abe07..1b036e19 100644 --- a/examples/email-agent/src/main/java/org/springaicommunity/claude/agent/examples/email/service/ClaudeService.java +++ b/examples/email-agent/src/main/java/org/springaicommunity/claude/agent/examples/email/service/ClaudeService.java @@ -44,7 +44,7 @@ public Flux streamText(String prompt) { .permissionMode(PermissionMode.BYPASS_PERMISSIONS) .build(); - return client.queryAndReceive(prompt) + return client.connect(prompt).messages() .doOnSubscribe(s -> log.info("[STREAM] Subscribed to ClaudeAsyncClient")) .doOnNext(msg -> log.debug("[STREAM] Message: {}", msg.getClass().getSimpleName())) .filter(msg -> msg instanceof AssistantMessage) diff --git a/examples/excel-demo/README.md b/examples/excel-demo/README.md index 20234059..e4358df7 100644 --- a/examples/excel-demo/README.md +++ b/examples/excel-demo/README.md @@ -87,7 +87,7 @@ public Flux streamText(String prompt) { .permissionMode(PermissionMode.BYPASS_PERMISSIONS) .build(); - return client.queryAndReceive(prompt) + return client.connect(prompt).messages() .filter(msg -> msg instanceof AssistantMessage) .flatMap(msg -> ((AssistantMessage) msg).getTextContent() .map(Mono::just).orElse(Mono.empty())) diff --git a/examples/excel-demo/src/main/java/org/springaicommunity/claude/agent/examples/excel/service/ClaudeService.java b/examples/excel-demo/src/main/java/org/springaicommunity/claude/agent/examples/excel/service/ClaudeService.java index bfa8f7d0..8d5e2026 100644 --- a/examples/excel-demo/src/main/java/org/springaicommunity/claude/agent/examples/excel/service/ClaudeService.java +++ b/examples/excel-demo/src/main/java/org/springaicommunity/claude/agent/examples/excel/service/ClaudeService.java @@ -67,7 +67,7 @@ public Flux streamText(String prompt, Path workingDirectory) { .permissionMode(PermissionMode.BYPASS_PERMISSIONS) .build(); - return client.queryAndReceive(prompt) + return client.connect(prompt).messages() .doOnSubscribe(s -> log.info("[STREAM] Subscribed to ClaudeAsyncClient")) .doOnNext(msg -> log.info("[STREAM] Message received: type={}", msg.getClass().getSimpleName())) .filter(msg -> msg instanceof AssistantMessage) @@ -139,7 +139,7 @@ public Flux streamMessages(String prompt) { .permissionMode(PermissionMode.BYPASS_PERMISSIONS) .build(); - return client.queryAndReceive(prompt) + return client.connect(prompt).messages() .doFinally(signal -> client.close().subscribe()); }