Skip to content

Commit

Permalink
Consistently log when property stores is invalidated
Browse files Browse the repository at this point in the history
PropStore was logging on some events that caused a need to refresh the
properties and not others.  Modified to consistently log whenever an
event caused the properties to be invalidated.
  • Loading branch information
keith-turner committed Oct 16, 2024
1 parent e733bd3 commit e038b32
Show file tree
Hide file tree
Showing 2 changed files with 5 additions and 3 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -152,6 +152,6 @@ public int hashCode() {
@Override
public String toString() {
return this.getClass().getSimpleName() + "{" + getId().getClass().getSimpleName() + "="
+ getId().canonical() + "'}";
+ getId().canonical() + "}";
}
}
Original file line number Diff line number Diff line change
Expand Up @@ -113,28 +113,30 @@ private void updateSnapshot() {
public void zkChangeEvent(final PropStoreKey<?> eventPropKey) {
if (propStoreKey.equals(eventPropKey)) {
requireUpdate();
log.debug("Saw zk change event for {} - update properties required", propStoreKey);
}
}

@Override
public void cacheChangeEvent(final PropStoreKey<?> eventPropKey) {
if (propStoreKey.equals(eventPropKey)) {
requireUpdate();
log.debug("Saw cache change event for {} - update properties required", propStoreKey);
}
}

@Override
public void deleteEvent(final PropStoreKey<?> eventPropKey) {
if (propStoreKey.equals(eventPropKey)) {
requireUpdate();
log.debug("Received property delete event for {}", propStoreKey);
log.debug("Received property delete event for {} - update properties required", propStoreKey);
}
}

@Override
public void connectionEvent() {
requireUpdate();
log.debug("Received connection event - update properties required");
log.debug("Received connection event for {} - update properties required", propStoreKey);
}

}

0 comments on commit e038b32

Please sign in to comment.