This is an automated email from the ASF dual-hosted git repository. davsclaus pushed a commit to branch kamelet2 in repository https://gitbox.apache.org/repos/asf/camel.git
commit 3714b8ae553a7d60f60b4b6a68c55919781fb419 Author: Claus Ibsen <[email protected]> AuthorDate: Sun Jan 26 09:48:29 2025 +0100 CAMEL-21599: camel-kamelet - Rework error handler for kamelets to be more standard Camel. WIP --- .../src/main/java/org/apache/camel/spi/LifecycleStrategy.java | 10 ---------- .../org/apache/camel/impl/engine/InternalServiceManager.java | 2 +- 2 files changed, 1 insertion(+), 11 deletions(-) diff --git a/core/camel-api/src/main/java/org/apache/camel/spi/LifecycleStrategy.java b/core/camel-api/src/main/java/org/apache/camel/spi/LifecycleStrategy.java index a1abcf2ec49..4b397c27f3c 100644 --- a/core/camel-api/src/main/java/org/apache/camel/spi/LifecycleStrategy.java +++ b/core/camel-api/src/main/java/org/apache/camel/spi/LifecycleStrategy.java @@ -111,16 +111,6 @@ public interface LifecycleStrategy { */ void onEndpointAdd(Endpoint endpoint); - /** - * Notification on adding an {@link Endpoint}. - * - * @param endpoint the added endpoint - * @param route the route the endpoint belongs to if any possible to determine - */ - default void onEndpointAdd(Endpoint endpoint, Route route) { - onEndpointAdd(endpoint); - } - /** * Notification on removing an {@link Endpoint}. * diff --git a/core/camel-base-engine/src/main/java/org/apache/camel/impl/engine/InternalServiceManager.java b/core/camel-base-engine/src/main/java/org/apache/camel/impl/engine/InternalServiceManager.java index 2bfa1305889..097ef832b56 100644 --- a/core/camel-base-engine/src/main/java/org/apache/camel/impl/engine/InternalServiceManager.java +++ b/core/camel-base-engine/src/main/java/org/apache/camel/impl/engine/InternalServiceManager.java @@ -107,7 +107,7 @@ final class InternalServiceManager { } if (service instanceof Endpoint endpoint) { // use specialized endpoint add - strategy.onEndpointAdd(endpoint, route); + strategy.onEndpointAdd(endpoint); } else { strategy.onServiceAdd(camelContext, service, route); }
