keep retry delay from packet
* keep retry delay if it's set to some specific (positive)
value in the reply already.
@@ -326,10 +326,14 @@ public class StoragePolicy extends ExternalSlobrokPolicy {
}
}
if (context.usedState != null && newState.getVersion() <= context.usedState.getVersion()) {
+ if (reply.getRetryDelay() <= 0.0) {
reply.setRetryDelay(-1);
+ }
} else {
+ if (reply.getRetryDelay() <= 0.0) {
reply.setRetryDelay(0);
}
+ }
if (context.calculatedDistributor == null) {
if (cachedClusterState == null) {
if (reply.getTrace().shouldTrace(1)) {
