[camel] 01/02: CAMEL-16900: camel-core - ExchangeFactory should create exchange with default MEP from its endpoint

[da...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

davsclaus pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel.git

commit 4376c777b2b8ac8acd9c7abb178781eb15cc5a12
Author: Claus Ibsen <cl...@gmail.com>
AuthorDate: Mon Aug 30 21:43:35 2021 +0200

    CAMEL-16900: camel-core - ExchangeFactory should create exchange with default MEP from its endpoint
---
 core/camel-api/src/main/java/org/apache/camel/Endpoint.java          | 5 +++++
 .../src/main/java/org/apache/camel/support/AbstractExchange.java     | 2 +-
 .../src/main/java/org/apache/camel/support/DefaultEndpoint.java      | 4 +---
 .../org/apache/camel/support/DefaultInterceptSendToEndpoint.java     | 5 +++++
 4 files changed, 12 insertions(+), 4 deletions(-)

diff --git a/core/camel-api/src/main/java/org/apache/camel/Endpoint.java b/core/camel-api/src/main/java/org/apache/camel/Endpoint.java
index a8301dc..0d449fa 100644
--- a/core/camel-api/src/main/java/org/apache/camel/Endpoint.java
+++ b/core/camel-api/src/main/java/org/apache/camel/Endpoint.java
@@ -38,6 +38,11 @@ public interface Endpoint extends IsSingleton, Service {
     String getEndpointUri();
 
     /**
+     * Returns the default exchange pattern to use when creating an exchange.
+     */
+    ExchangePattern getExchangePattern();
+
+    /**
      * Returns the string representation of the base endpoint URI (without query parameters).
      */
     default String getEndpointBaseUri() {
diff --git a/core/camel-support/src/main/java/org/apache/camel/support/AbstractExchange.java b/core/camel-support/src/main/java/org/apache/camel/support/AbstractExchange.java
index 13fb236..55b0b9a 100644
--- a/core/camel-support/src/main/java/org/apache/camel/support/AbstractExchange.java
+++ b/core/camel-support/src/main/java/org/apache/camel/support/AbstractExchange.java
@@ -110,7 +110,7 @@ class AbstractExchange implements ExtendedExchange {
 
     public AbstractExchange(Endpoint fromEndpoint) {
         this.context = fromEndpoint.getCamelContext();
-        this.pattern = ExchangePattern.InOnly;
+        this.pattern = fromEndpoint.getExchangePattern();
         this.created = System.currentTimeMillis();
         this.fromEndpoint = fromEndpoint;
     }
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 9c4319c..e23bbef 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
@@ -246,9 +246,7 @@ public abstract class DefaultEndpoint extends ServiceSupport implements Endpoint
         // noop
     }
 
-    /**
-     * Returns the default exchange pattern to use when creating an exchange.
-     */
+    @Override
     public ExchangePattern getExchangePattern() {
         return exchangePattern;
     }
diff --git a/core/camel-support/src/main/java/org/apache/camel/support/DefaultInterceptSendToEndpoint.java b/core/camel-support/src/main/java/org/apache/camel/support/DefaultInterceptSendToEndpoint.java
index 99692e0..5f9b946 100644
--- a/core/camel-support/src/main/java/org/apache/camel/support/DefaultInterceptSendToEndpoint.java
+++ b/core/camel-support/src/main/java/org/apache/camel/support/DefaultInterceptSendToEndpoint.java
@@ -93,6 +93,11 @@ public class DefaultInterceptSendToEndpoint implements InterceptSendToEndpoint,
     }
 
     @Override
+    public ExchangePattern getExchangePattern() {
+        return delegate.getExchangePattern();
+    }
+
+    @Override
     public String getEndpointBaseUri() {
         return delegate.getEndpointBaseUri();
     }