Skip to content

Commit

Permalink
Augmenting registry backoff
Browse files Browse the repository at this point in the history
  • Loading branch information
grafnu committed Apr 20, 2024
1 parent 954b0fc commit 7a6dd52
Showing 1 changed file with 3 additions and 4 deletions.
Original file line number Diff line number Diff line change
@@ -1,6 +1,5 @@
package com.google.bos.udmi.service.access;

import static com.google.common.base.Strings.isNullOrEmpty;
import static com.google.udmi.util.GeneralUtils.CSV_JOINER;
import static com.google.udmi.util.GeneralUtils.friendlyStackTrace;
import static com.google.udmi.util.GeneralUtils.ifNotNullGet;
Expand Down Expand Up @@ -162,8 +161,8 @@ private boolean registryBackoffCheck(String registryId, String deviceId) {

private void registryBackoffClear(String registryId, String deviceId) {
String backoffKey = getBackoffKey(registryId, deviceId);
ifNotNullThen(BACKOFF_MAP.remove(backoffKey),
() -> debug("Released registry backoff for " + backoffKey));
ifNotNullThen(BACKOFF_MAP.remove(backoffKey), removed -> debug(
"Released registry backoff for " + backoffKey + " was " + isoConvert(removed)));
}

private Instant registryBackoffInhibit(String registryId, String deviceId) {
Expand Down Expand Up @@ -283,7 +282,7 @@ public final void sendCommand(String registryId, String deviceId, SubFolder fold
backoffKey, isoConvert(until)));
}
} else {
debug("Dropping message because registry backoff for %s", backoffKey);
debug("Dropping message because registry backoff for %s active", backoffKey);
}
}

Expand Down

0 comments on commit 7a6dd52

Please sign in to comment.