private void maybeBackoff()

in crossdc-consumer/src/main/java/org/apache/solr/crossdc/messageprocessor/SolrMessageProcessor.java [124:136]


    private void maybeBackoff(SolrException solrException) {
        if (solrException == null) {
            return;
        }
        long sleepTimeMs = 1000;
        String backoffTimeSuggested = solrException.getMetadata("backoffTime-ms");
        if (backoffTimeSuggested != null && !"0".equals(backoffTimeSuggested)) {
            // If backoff policy is not configured (returns "0" by default), then sleep 1 second. If configured, do as it says.
            sleepTimeMs = Math.max(1, Long.parseLong(backoffTimeSuggested));
        }
        log.info("Consumer backoff. sleepTimeMs={}", sleepTimeMs);
        uncheckedSleep(sleepTimeMs);
    }