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

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

commit 7e6da1de5bb709d7046b9b4f458d9882a642d72c
Author: Otavio Rodolfo Piske <angusyo...@gmail.com>
AuthorDate: Tue Nov 22 18:34:32 2022 +0100

    CAMEL-15105: adapt DefaultConsumerTemplate to the new extension interface
---
 .../java/org/apache/camel/impl/engine/DefaultConsumerTemplate.java     | 3 +--
 1 file changed, 1 insertion(+), 2 deletions(-)

diff --git 
a/core/camel-base-engine/src/main/java/org/apache/camel/impl/engine/DefaultConsumerTemplate.java
 
b/core/camel-base-engine/src/main/java/org/apache/camel/impl/engine/DefaultConsumerTemplate.java
index e0abf0e5f68..00914f4b8e0 100644
--- 
a/core/camel-base-engine/src/main/java/org/apache/camel/impl/engine/DefaultConsumerTemplate.java
+++ 
b/core/camel-base-engine/src/main/java/org/apache/camel/impl/engine/DefaultConsumerTemplate.java
@@ -22,7 +22,6 @@ import org.apache.camel.CamelContext;
 import org.apache.camel.ConsumerTemplate;
 import org.apache.camel.Endpoint;
 import org.apache.camel.Exchange;
-import org.apache.camel.ExtendedExchange;
 import org.apache.camel.spi.ConsumerCache;
 import org.apache.camel.spi.Synchronization;
 import org.apache.camel.support.CamelContextHelper;
@@ -219,7 +218,7 @@ public class DefaultConsumerTemplate extends ServiceSupport 
implements ConsumerT
             }
             if (exchange.getUnitOfWork() == null) {
                 // handover completions and done them manually to ensure they 
are being executed
-                List<Synchronization> synchronizations = 
exchange.adapt(ExtendedExchange.class).handoverCompletions();
+                List<Synchronization> synchronizations = 
exchange.getExchangeExtension().handoverCompletions();
                 UnitOfWorkHelper.doneSynchronizations(exchange, 
synchronizations, LOG);
             } else {
                 // done the unit of work

Reply via email to