(camel) branch main updated: camel-core: no need for state for stream caching advice

[davsclaus]

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

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


The following commit(s) were added to refs/heads/main by this push:
     new 3588e029625a camel-core: no need for state for stream caching advice
3588e029625a is described below

commit 3588e029625a43ece317b2d930a9313a816d65ff
Author: Claus Ibsen <claus.ib...@gmail.com>
AuthorDate: Sat Dec 27 18:45:56 2025 +0100

    camel-core: no need for state for stream caching advice
---
 .../apache/camel/impl/engine/CamelInternalProcessor.java  | 15 ++++++++++-----
 1 file changed, 10 insertions(+), 5 deletions(-)

diff --git 
a/core/camel-base-engine/src/main/java/org/apache/camel/impl/engine/CamelInternalProcessor.java
 
b/core/camel-base-engine/src/main/java/org/apache/camel/impl/engine/CamelInternalProcessor.java
index f7bd87d4c9a5..d86ef0f57c62 100644
--- 
a/core/camel-base-engine/src/main/java/org/apache/camel/impl/engine/CamelInternalProcessor.java
+++ 
b/core/camel-base-engine/src/main/java/org/apache/camel/impl/engine/CamelInternalProcessor.java
@@ -40,7 +40,6 @@ import org.apache.camel.Ordered;
 import org.apache.camel.Processor;
 import org.apache.camel.Route;
 import org.apache.camel.StatefulService;
-import org.apache.camel.StreamCache;
 import org.apache.camel.impl.debugger.BacklogTracer;
 import org.apache.camel.impl.debugger.DefaultBacklogTracerEventMessage;
 import org.apache.camel.spi.BacklogDebugger;
@@ -1066,7 +1065,7 @@ public class CamelInternalProcessor extends 
DelegateAsyncProcessor implements In
     /**
      * Advice for {@link org.apache.camel.spi.StreamCachingStrategy}
      */
-    public static class StreamCachingAdvice implements 
CamelInternalProcessorAdvice<StreamCache>, Ordered {
+    public static class StreamCachingAdvice implements 
CamelInternalProcessorAdvice, Ordered {
 
         private final StreamCachingStrategy strategy;
 
@@ -1075,16 +1074,22 @@ public class CamelInternalProcessor extends 
DelegateAsyncProcessor implements In
         }
 
         @Override
-        public StreamCache before(Exchange exchange) throws Exception {
-            return StreamCachingHelper.convertToStreamCache(strategy, 
exchange, exchange.getIn());
+        public Object before(Exchange exchange) throws Exception {
+            StreamCachingHelper.convertToStreamCache(strategy, exchange, 
exchange.getIn());
+            return null;
         }
 
         @Override
-        public void after(Exchange exchange, StreamCache sc) throws Exception {
+        public void after(Exchange exchange, Object data) throws Exception {
             // reset cached streams so they can be read again
             MessageHelper.resetStreamCache(exchange.getMessage());
         }
 
+        @Override
+        public boolean hasState() {
+            return false;
+        }
+
         @Override
         public int getOrder() {
             // we want stream caching first