using System;

using System.Threading.Tasks;

using System.Collections.Generic;

using Policy = Polly.Policy;

using Polly.Retry;

using Polly;        

using Polly.Contrib.WaitAndRetry;

​

public class Program

{

    static readonly IEnumerable<TimeSpan> topicRetryDelay = Backoff.DecorrelatedJitterBackoffV2(TimeSpan.FromMilliseconds(100), retryCount: 5);

​

     static AsyncRetryPolicy topicRetryPolicy = Policy

     .Handle<Exception>( ex => ex.Message.Contains("Rate exceeded"))

     .WaitAndRetryAsync(topicRetryDelay);

    public static async Task Main()

    {

        await topicRetryPolicy.ExecuteAsync(() => { Console.WriteLine($"Try {DateTime.Now}"); throw new Exception("Rate exceeded"); } );

    }

​

}