This is an automated email from the ASF dual-hosted git repository. davsclaus pushed a commit to branch camel-3.11.x in repository https://gitbox.apache.org/repos/asf/camel.git
The following commit(s) were added to refs/heads/camel-3.11.x by this push: new 5be4bb2 [CAMEL-17618]follow up fix and re-enable failure test (#6938) 5be4bb2 is described below commit 5be4bb2646f99b540f0d4a2d981719392d946072 Author: Freeman(Yue) Fang <freeman.f...@gmail.com> AuthorDate: Sat Feb 12 02:19:20 2022 -0500 [CAMEL-17618]follow up fix and re-enable failure test (#6938) --- .../src/main/java/org/apache/camel/component/ref/RefEndpoint.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/components/camel-ref/src/main/java/org/apache/camel/component/ref/RefEndpoint.java b/components/camel-ref/src/main/java/org/apache/camel/component/ref/RefEndpoint.java index caef53d8..07f8859 100644 --- a/components/camel-ref/src/main/java/org/apache/camel/component/ref/RefEndpoint.java +++ b/components/camel-ref/src/main/java/org/apache/camel/component/ref/RefEndpoint.java @@ -77,7 +77,8 @@ public class RefEndpoint extends DefaultEndpoint implements DelegateEndpoint { if (endpoint == null) { // endpoint is mandatory endpoint = CamelContextHelper.mandatoryLookup(getCamelContext(), name, Endpoint.class); - if (getCamelContext().getEndpoint(getEndpoint().getEndpointUri()) == null) { + if (getCamelContext().getEndpoint(getEndpoint().getEndpointUri()) == null + || getCamelContext().getEndpoint(getEndpoint().getEndpointUri()) != endpoint) { getCamelContext().addEndpoint(getEndpoint().getEndpointUri(), endpoint); } }