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 2020/01/31 05:24:31 UTC
[camel] 01/08: CAMEL-14354: camel-core optimize
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 692a4096b247d821bb9d95eb83690f9619b33a99
Author: Claus Ibsen <cl...@gmail.com>
AuthorDate: Thu Jan 30 09:22:09 2020 +0100
CAMEL-14354: camel-core optimize
---
.../main/java/org/apache/camel/support/DefaultEndpoint.java | 2 +-
.../main/java/org/apache/camel/support/DefaultExchange.java | 13 ++++++++++---
2 files changed, 11 insertions(+), 4 deletions(-)
diff --git a/core/camel-support/src/main/java/org/apache/camel/support/DefaultEndpoint.java b/core/camel-support/src/main/java/org/apache/camel/support/DefaultEndpoint.java
index d0dea66..f247f27 100644
--- a/core/camel-support/src/main/java/org/apache/camel/support/DefaultEndpoint.java
+++ b/core/camel-support/src/main/java/org/apache/camel/support/DefaultEndpoint.java
@@ -228,7 +228,7 @@ public abstract class DefaultEndpoint extends ServiceSupport implements Endpoint
@Override
public Exchange createExchange() {
- return createExchange(getExchangePattern());
+ return new DefaultExchange(this, getExchangePattern());
}
@Override
diff --git a/core/camel-support/src/main/java/org/apache/camel/support/DefaultExchange.java b/core/camel-support/src/main/java/org/apache/camel/support/DefaultExchange.java
index f24281a..71220ae 100644
--- a/core/camel-support/src/main/java/org/apache/camel/support/DefaultExchange.java
+++ b/core/camel-support/src/main/java/org/apache/camel/support/DefaultExchange.java
@@ -68,7 +68,9 @@ public final class DefaultExchange implements ExtendedExchange {
private Boolean errorHandlerHandled;
public DefaultExchange(CamelContext context) {
- this(context, ExchangePattern.InOnly);
+ this.context = context;
+ this.pattern = ExchangePattern.InOnly;
+ this.created = System.currentTimeMillis();
}
public DefaultExchange(CamelContext context, ExchangePattern pattern) {
@@ -87,11 +89,16 @@ public final class DefaultExchange implements ExtendedExchange {
}
public DefaultExchange(Endpoint fromEndpoint) {
- this(fromEndpoint, ExchangePattern.InOnly);
+ this.context = fromEndpoint.getCamelContext();
+ this.pattern = ExchangePattern.InOnly;
+ this.created = System.currentTimeMillis();
+ this.fromEndpoint = fromEndpoint;
}
public DefaultExchange(Endpoint fromEndpoint, ExchangePattern pattern) {
- this(fromEndpoint.getCamelContext(), pattern);
+ this.context = fromEndpoint.getCamelContext();
+ this.pattern = pattern;
+ this.created = System.currentTimeMillis();
this.fromEndpoint = fromEndpoint;
}