From 51a8fe509cd72d47bd94c35282f5f149e9d45cf7 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Attila=20M=C3=A9sz=C3=A1ros?= Date: Thu, 25 Jan 2024 13:54:00 +0100 Subject: [PATCH] fix: dynamic event source registration should not return named event source (#2219) MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit Signed-off-by: Attila Mészáros --- .../operator/processing/event/EventSourceManager.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/operator-framework-core/src/main/java/io/javaoperatorsdk/operator/processing/event/EventSourceManager.java b/operator-framework-core/src/main/java/io/javaoperatorsdk/operator/processing/event/EventSourceManager.java index f9304b6ca6..bd299b464a 100644 --- a/operator-framework-core/src/main/java/io/javaoperatorsdk/operator/processing/event/EventSourceManager.java +++ b/operator-framework-core/src/main/java/io/javaoperatorsdk/operator/processing/event/EventSourceManager.java @@ -234,7 +234,7 @@ public EventSource dynamicallyRegisterEventSource(String name, synchronized (this) { var actual = eventSources.existing(name, eventSource); if (actual != null) { - eventSource = actual; + eventSource = actual.eventSource(); } else { registerEventSource(name, eventSource); }