(camel-quarkus) branch main updated: Fix flaky test OpenaiTest.streaming

[jamesnetherton]

This is an automated email from the ASF dual-hosted git repository.

jamesnetherton pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel-quarkus.git


The following commit(s) were added to refs/heads/main by this push:
     new 9dbab1c5ee Fix flaky test OpenaiTest.streaming
9dbab1c5ee is described below

commit 9dbab1c5eeaf82c30b507679c7b0946d8f24f87c
Author: James Netherton <jamesnether...@gmail.com>
AuthorDate: Tue Feb 3 07:26:35 2026 +0000

    Fix flaky test OpenaiTest.streaming
---
 .../apache/camel/quarkus/component/openai/it/OpenaiRoutes.java   | 9 ++++-----
 .../org/apache/camel/quarkus/component/openai/it/OpenaiTest.java | 2 +-
 2 files changed, 5 insertions(+), 6 deletions(-)

diff --git 
a/integration-tests/openai/src/main/java/org/apache/camel/quarkus/component/openai/it/OpenaiRoutes.java
 
b/integration-tests/openai/src/main/java/org/apache/camel/quarkus/component/openai/it/OpenaiRoutes.java
index a8eb914d21..46a0aae44c 100644
--- 
a/integration-tests/openai/src/main/java/org/apache/camel/quarkus/component/openai/it/OpenaiRoutes.java
+++ 
b/integration-tests/openai/src/main/java/org/apache/camel/quarkus/component/openai/it/OpenaiRoutes.java
@@ -26,6 +26,7 @@ import org.apache.camel.Processor;
 import org.apache.camel.builder.RouteBuilder;
 import org.apache.camel.quarkus.component.openai.it.model.Product;
 import org.apache.camel.util.ObjectHelper;
+import org.apache.camel.util.StringHelper;
 
 public class OpenaiRoutes extends RouteBuilder {
 
@@ -44,18 +45,16 @@ public class OpenaiRoutes extends RouteBuilder {
                     public void process(Exchange exchange) throws Exception {
                         Message message = exchange.getMessage();
                         ChatCompletionChunk chunk = 
message.getBody(ChatCompletionChunk.class);
+                        message.setBody(null);
+
                         List<Choice> choices = chunk.choices();
                         if (!choices.isEmpty()) {
                             Choice choice = choices.get(0);
                             choice.delta().content().ifPresent(content -> {
-                                if (ObjectHelper.isNotEmpty(content) && 
!content.equals("\n")) {
+                                if (ObjectHelper.isNotEmpty(content) && 
StringHelper.isDigit(content)) {
                                     message.setBody(content);
-                                } else {
-                                    message.setBody(null);
                                 }
                             });
-                        } else {
-                            message.setBody(null);
                         }
                     }
                 })
diff --git 
a/integration-tests/openai/src/test/java/org/apache/camel/quarkus/component/openai/it/OpenaiTest.java
 
b/integration-tests/openai/src/test/java/org/apache/camel/quarkus/component/openai/it/OpenaiTest.java
index 464c22ede1..c9c87f6dc7 100644
--- 
a/integration-tests/openai/src/test/java/org/apache/camel/quarkus/component/openai/it/OpenaiTest.java
+++ 
b/integration-tests/openai/src/test/java/org/apache/camel/quarkus/component/openai/it/OpenaiTest.java
@@ -169,7 +169,7 @@ class OpenaiTest {
 
                     if (response.getStatusCode() == 200) {
                         String result = response.getBody().asString();
-                        if (result != null && !result.isBlank()) {
+                        if (result != null) {
                             receivedNumbers.add(result.trim());
                         }
                     }