This is an automated email from the ASF dual-hosted git repository. JiriOndrusek pushed a commit to branch camel-main in repository https://gitbox.apache.org/repos/asf/camel-quarkus.git
commit 3e884f7417b508cdd59c831ceb361be1afb312fe Author: jiriOndrusek-agent <[email protected]> AuthorDate: Thu Nov 5 09:56:10 2026 +0000 Reply with a PongResponse in the grpc forwardOnError route CAMEL-26187 fails the call when the reply does not convert to the response type. Co-Authored-By: Claude Opus 5.5 <[email protected]> --- .../org/apache/camel/quarkus/component/grpc/it/GrpcRoute.java | 8 ++++++-- 1 file changed, 6 insertions(+), 2 deletions(-) diff --git a/integration-tests/grpc/src/main/java/org/apache/camel/quarkus/component/grpc/it/GrpcRoute.java b/integration-tests/grpc/src/main/java/org/apache/camel/quarkus/component/grpc/it/GrpcRoute.java index 2d95d060218..c813d038e70 100644 --- a/integration-tests/grpc/src/main/java/org/apache/camel/quarkus/component/grpc/it/GrpcRoute.java +++ b/integration-tests/grpc/src/main/java/org/apache/camel/quarkus/component/grpc/it/GrpcRoute.java @@ -86,8 +86,12 @@ public class GrpcRoute extends RouteBuilder { // Forward on error consumer fromF("grpc://localhost:{{camel.grpc.test.forward.error.server.port}}/%s?consumerStrategy=PROPAGATION&forwardOnError=true", PING_PONG_SERVICE) - .filter().body(Throwable.class) - .to("mock:forwardOnError"); + .choice() + .when(body().isInstanceOf(Throwable.class)) + .to("mock:forwardOnError") + .otherwise() + // the reply must be a PongResponse + .process(new GrpcProcessor()); // Route controlled stream observer consumer fromF("grpc://localhost:{{camel.grpc.test.route.controlled.server.port}}/%s?synchronous=true&consumerStrategy=PROPAGATION&routeControlledStreamObserver=true",
