fix(client): Add delay within catch block in JobWorker.PollJobs to avoid server hogging.

Client/Impl/Commands/ActivateJobsCommand.cs

@@ -4,6 +4,7 @@
 using System.Threading.Tasks;
 using GatewayProtocol;
 using Zeebe.Client.Api.Commands;
+using Zeebe.Client.Api.Misc;
 using Zeebe.Client.Api.Responses;
 using static GatewayProtocol.Gateway;
 
@@ -13,9 +14,11 @@ internal class ActivateJobsCommand : IActivateJobsCommandStep1, IActivateJobsCom
     {
         private readonly JobActivator activator;
         public ActivateJobsRequest Request { get; }
+        private readonly IAsyncRetryStrategy asyncRetryStrategy;
 
-        public ActivateJobsCommand(GatewayClient client)
+        public ActivateJobsCommand(GatewayClient client, IAsyncRetryStrategy asyncRetryStrategy)
         {
+            this.asyncRetryStrategy = asyncRetryStrategy;
             activator = new JobActivator(client);
             Request = new ActivateJobsRequest();
         }
@@ -72,9 +75,14 @@ public async Task<IActivateJobsResponse> Send(TimeSpan? timeout, CancellationTok
             return await activator.SendActivateRequest(Request, timeout?.FromUtcNow(), cancellationToken);
         }
 
-        public Task<IActivateJobsResponse> SendWithRetry(TimeSpan? timespan = null)
+        public async Task<IActivateJobsResponse> SendWithRetry(TimeSpan? timespan)
         {
-            throw new NotImplementedException();
+            return await asyncRetryStrategy.DoWithRetry(() => Send(timespan));
+        }
+
+        public async Task<IActivateJobsResponse> SendWithRetry(TimeSpan? timespan, CancellationToken? cancellationToken)
+        {
+            return await asyncRetryStrategy.DoWithRetry(() => Send(timespan, cancellationToken));
         }
     }
 }

Client/Impl/Worker/JobWorker.cs

@@ -145,7 +145,7 @@ private async Task PollJobs(ITargetBlock<IJob> input, CancellationToken cancella
 
                     try
                     {
-                        var response = await activateJobsCommand.Send(null, cancellationToken);
+                        var response = await activateJobsCommand.SendWithRetry(null, cancellationToken);
                         await HandleActivationResponse(input, response, jobCount);
                     }
                     catch (RpcException rpcException)

Client/ZeebeClient.cs

@@ -102,7 +102,7 @@ public IJobWorkerBuilderStep1 NewWorker()
 
         public IActivateJobsCommandStep1 NewActivateJobsCommand()
         {
-            return new ActivateJobsCommand(gatewayClient);
+            return new ActivateJobsCommand(gatewayClient, asyncRetryStrategy);
         }
 
         public ICompleteJobCommandStep1 NewCompleteJobCommand(long jobKey)