Skip to content

Commit 754c730

Browse files
committed
fix: additional log message
1 parent 534f2cf commit 754c730

File tree

1 file changed

+10
-4
lines changed
  • operator-framework-core/src/main/java/io/javaoperatorsdk/operator/processing/event/source/informer

1 file changed

+10
-4
lines changed

operator-framework-core/src/main/java/io/javaoperatorsdk/operator/processing/event/source/informer/InformerEventSource.java

Lines changed: 10 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -85,11 +85,17 @@ public InformerEventSource(InformerConfiguration<R, P> configuration, Kubernetes
8585

8686
@Override
8787
public void onAdd(R resource) {
88+
if (log.isDebugEnabled()) {
89+
log.debug("On add event received for resource id: {}", ResourceID.fromResource(resource));
90+
}
8891
onAddOrUpdate("add", resource, () -> InformerEventSource.super.onAdd(resource));
8992
}
9093

9194
@Override
9295
public void onUpdate(R oldObject, R newObject) {
96+
if (log.isDebugEnabled()) {
97+
log.debug("On update event received for resource id: {}", ResourceID.fromResource(newObject));
98+
}
9399
onAddOrUpdate("update", newObject,
94100
() -> InformerEventSource.super.onUpdate(oldObject, newObject));
95101
}
@@ -118,12 +124,12 @@ private synchronized void onAddOrUpdate(String operation, R newObject, Runnable
118124
}
119125

120126
@Override
121-
public void onDelete(R r, boolean b) {
127+
public void onDelete(R resource, boolean b) {
122128
if (log.isDebugEnabled()) {
123-
log.debug("On delete event received for resource id: {}", ResourceID.fromResource(r));
129+
log.debug("On delete event received for resource id: {}", ResourceID.fromResource(resource));
124130
}
125-
super.onDelete(r, b);
126-
propagateEvent(r);
131+
super.onDelete(resource, b);
132+
propagateEvent(resource);
127133
}
128134

129135
private void propagateEvent(R object) {

0 commit comments

Comments
 (0)