You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by da...@apache.org on 2021/02/27 20:47:51 UTC
[camel] branch master updated (3d94479 -> 28f7d45)
This is an automated email from the ASF dual-hosted git repository.
davsclaus pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/camel.git.
from 3d94479 Sync deps
new f739937 Polished
new 28f7d45 camel-core - Small optimization in pipeline
The 2 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../main/java/org/apache/camel/component/http/HttpProducer.java | 1 -
.../src/main/java/org/apache/camel/processor/Pipeline.java | 9 +++++++--
2 files changed, 7 insertions(+), 3 deletions(-)
[camel] 01/02: Polished
Posted by da...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
davsclaus pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/camel.git
commit f739937b6e0adfd7848eb944463d2746c3e78ae1
Author: Claus Ibsen <cl...@gmail.com>
AuthorDate: Sat Feb 27 18:39:05 2021 +0100
Polished
---
.../src/main/java/org/apache/camel/component/http/HttpProducer.java | 1 -
1 file changed, 1 deletion(-)
diff --git a/components/camel-http/src/main/java/org/apache/camel/component/http/HttpProducer.java b/components/camel-http/src/main/java/org/apache/camel/component/http/HttpProducer.java
index d20df05..048f8a5 100644
--- a/components/camel-http/src/main/java/org/apache/camel/component/http/HttpProducer.java
+++ b/components/camel-http/src/main/java/org/apache/camel/component/http/HttpProducer.java
@@ -97,7 +97,6 @@ public class HttpProducer extends DefaultProducer {
private int maxOkRange;
private String defaultUrl;
private URI defaultUri;
- private URI defaultRelativeUri;
private HttpHost defaultHttpHost;
public HttpProducer(HttpEndpoint endpoint) {
[camel] 02/02: camel-core - Small optimization in pipeline
Posted by da...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
davsclaus pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/camel.git
commit 28f7d4567bb6eb419ed245d171c783e8e727dfbb
Author: Claus Ibsen <cl...@gmail.com>
AuthorDate: Sat Feb 27 21:41:07 2021 +0100
camel-core - Small optimization in pipeline
---
.../src/main/java/org/apache/camel/processor/Pipeline.java | 9 +++++++--
1 file changed, 7 insertions(+), 2 deletions(-)
diff --git a/core/camel-core-processor/src/main/java/org/apache/camel/processor/Pipeline.java b/core/camel-core-processor/src/main/java/org/apache/camel/processor/Pipeline.java
index aeb396d..0beeea6 100644
--- a/core/camel-core-processor/src/main/java/org/apache/camel/processor/Pipeline.java
+++ b/core/camel-core-processor/src/main/java/org/apache/camel/processor/Pipeline.java
@@ -57,7 +57,7 @@ public class Pipeline extends AsyncProcessorSupport implements Navigate<Processo
private String id;
private String routeId;
- private final class PipelineTask implements Runnable {
+ private final class PipelineTask implements Runnable, AsyncCallback {
private final Exchange exchange;
private final AsyncCallback callback;
@@ -70,6 +70,11 @@ public class Pipeline extends AsyncProcessorSupport implements Navigate<Processo
}
@Override
+ public void done(boolean doneSync) {
+ reactiveExecutor.schedule(this);
+ }
+
+ @Override
public void run() {
boolean stop = exchange.isRouteStop();
int num = index.get();
@@ -87,7 +92,7 @@ public class Pipeline extends AsyncProcessorSupport implements Navigate<Processo
// get the next processor
AsyncProcessor processor = processors.get(index.getAndIncrement());
- processor.process(exchange, doneSync -> reactiveExecutor.schedule(this));
+ processor.process(exchange, this);
} else {
ExchangeHelper.copyResults(exchange, exchange);