[camel] 13/23: CAMEL-15105: adapt the DefaultConsumer to the new extension interface

[orpiske]

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 d5989c41660b9ab6e28f33af942a26b4882c6171
Author: Otavio Rodolfo Piske <angusyo...@gmail.com>
AuthorDate: Tue Nov 22 18:34:15 2022 +0100

    CAMEL-15105: adapt the DefaultConsumer to the new extension interface
---
 .../src/main/java/org/apache/camel/support/DefaultConsumer.java   | 8 +++-----
 1 file changed, 3 insertions(+), 5 deletions(-)

diff --git 
a/core/camel-support/src/main/java/org/apache/camel/support/DefaultConsumer.java
 
b/core/camel-support/src/main/java/org/apache/camel/support/DefaultConsumer.java
index df40967f49d..7d773fcfb3e 100644
--- 
a/core/camel-support/src/main/java/org/apache/camel/support/DefaultConsumer.java
+++ 
b/core/camel-support/src/main/java/org/apache/camel/support/DefaultConsumer.java
@@ -22,7 +22,6 @@ import org.apache.camel.Consumer;
 import org.apache.camel.Endpoint;
 import org.apache.camel.Exchange;
 import org.apache.camel.ExtendedCamelContext;
-import org.apache.camel.ExtendedExchange;
 import org.apache.camel.PooledExchange;
 import org.apache.camel.Processor;
 import org.apache.camel.Route;
@@ -115,7 +114,7 @@ public class DefaultConsumer extends ServiceSupport 
implements Consumer, RouteAw
         if (uow == null) {
             uow = 
endpoint.getCamelContext().adapt(ExtendedCamelContext.class).getUnitOfWorkFactory()
                     .createUnitOfWork(exchange);
-            exchange.adapt(ExtendedExchange.class).setUnitOfWork(uow);
+            exchange.getExchangeExtension().setUnitOfWork(uow);
         }
         return uow;
     }
@@ -155,11 +154,10 @@ public class DefaultConsumer extends ServiceSupport 
implements Consumer, RouteAw
     public AsyncCallback defaultConsumerCallback(Exchange exchange, boolean 
autoRelease) {
         boolean pooled = exchangeFactory.isPooled();
         if (pooled) {
-            ExtendedExchange ee = exchange.adapt(ExtendedExchange.class);
-            AsyncCallback answer = ee.getDefaultConsumerCallback();
+            AsyncCallback answer = 
exchange.getExchangeExtension().getDefaultConsumerCallback();
             if (answer == null) {
                 answer = new DefaultConsumerCallback(this, exchange, 
autoRelease);
-                ee.setDefaultConsumerCallback(answer);
+                
exchange.getExchangeExtension().setDefaultConsumerCallback(answer);
             }
             return answer;
         } else {