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 2025/01/27 10:12:58 UTC
(camel) 02/13: CAMEL-21599: camel-kamelet - Rework error handler for kamelets to be more standard Camel. WIP
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 <cl...@gmail.com>
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);
}