Skip to content

Commit d537da2

Browse files
committed
refactor: initialize EventMarker at declaration point
1 parent 2a5a013 commit d537da2

File tree

1 file changed

+1
-2
lines changed
  • operator-framework-core/src/main/java/io/javaoperatorsdk/operator/processing/event

1 file changed

+1
-2
lines changed

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

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -50,7 +50,7 @@ class EventProcessor<R extends HasMetadata> implements EventHandler, LifecycleAw
5050
private volatile boolean running;
5151
private final ResourceCache<R> resourceCache;
5252
private final EventSourceManager<R> eventSourceManager;
53-
private final EventMarker eventMarker;
53+
private final EventMarker eventMarker = new EventMarker();
5454

5555
EventProcessor(EventSourceManager<R> eventSourceManager) {
5656
this(
@@ -88,7 +88,6 @@ private EventProcessor(ResourceCache<R> resourceCache, ExecutorService executor,
8888
this.retry = retry;
8989
this.resourceCache = resourceCache;
9090
this.metrics = metrics != null ? metrics : Metrics.NOOP;
91-
this.eventMarker = new EventMarker();
9291
this.eventSourceManager = eventSourceManager;
9392
}
9493

0 commit comments

Comments
 (0)