Skip to content

Commit 8c1b5c3

Browse files
committed
fix: register retry event source after event handler is created
1 parent a1dd153 commit 8c1b5c3

File tree

1 file changed

+4
-1
lines changed

1 file changed

+4
-1
lines changed

operator-framework-core/src/main/java/io/javaoperatorsdk/operator/processing/event/EventSourceManager.java

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -45,11 +45,14 @@ public class EventSourceManager<R extends HasMetadata> implements LifecycleAware
4545

4646
public EventSourceManager(Controller<R> controller) {
4747
this.controller = controller;
48-
registerEventSource(eventSources.initRetryEventSource());
4948

5049
// controller event source needs to be available before we create the event processor
5150
final var controllerEventSource = eventSources.initControllerEventSource(controller);
5251
this.eventProcessor = new EventProcessor<>(this);
52+
53+
// sources need to be registered after the event processor is created since it's set on the
54+
// event source
55+
registerEventSource(eventSources.initRetryEventSource());
5356
registerEventSource(controllerEventSource);
5457
}
5558

0 commit comments

Comments
 (0)