You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by or...@apache.org on 2023/02/14 12:53:58 UTC
[camel] 13/23: CAMEL-15105: adapt the DefaultConsumer to the new extension interface
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 <an...@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 {