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