improve performace for SQS

Author: abuzuhri

Source/FikaAmazonAPI.SampleCode/CustomMessageReceiver.cs

@@ -1,11 +1,5 @@
-using Amazon;
-using FikaAmazonAPI.NotificationMessages;
+using FikaAmazonAPI.NotificationMessages;
 using FikaAmazonAPI.Parameter.Notification;
-using System;
-using System.Collections.Generic;
-using System.Linq;
-using System.Text;
-using System.Threading.Tasks;
 
 namespace FikaAmazonAPI.SampleCode
 {
@@ -19,6 +13,7 @@ public void ErrorCatch(Exception ex)
 
         public void NewMessageRevicedTriger(NotificationMessageResponce message)
         {
+            Console.Write(".");
             //Your Code here
         }
     }

Source/FikaAmazonAPI/Services/NotificationService.cs

@@ -140,20 +140,12 @@ public async Task StartReceivingNotificationMessagesAsync(ParameterMessageReceiv
                         {
                             foreach (var msg in Messages)
                             {
-                                try
-                                {
-                                    var data = DeserializeNotification(msg);
-
-                                    messageReceiver.NewMessageRevicedTriger(data);
-                                    await DeleteMessageFromQueueAsync(amazonSQSClient, SQS_URL, msg.ReceiptHandle, cancellationToken);
-                                }
-                                catch (Exception ex)
-                                {
-                                    messageReceiver.ErrorCatch(ex);
-                                    await DeleteMessageFromQueueAsync(amazonSQSClient, SQS_URL, msg.ReceiptHandle, cancellationToken);
-                                }
+                                ProcessAnyOfferChangedMessage(msg, messageReceiver, amazonSQSClient, SQS_URL, cancellationToken).ConfigureAwait(false);
 
                             }
+
+                            if (Messages.Count < 10)
+                                Thread.Sleep(1000 * 5);
                         }
                     }
                     catch (Exception ex)
@@ -163,6 +155,22 @@ public async Task StartReceivingNotificationMessagesAsync(ParameterMessageReceiv
                 }
             }
         }
+
+        private async Task ProcessAnyOfferChangedMessage(Message msg, IMessageReceiver messageReceiver, AmazonSQSClient amazonSQSClient, string SQS_URL, CancellationToken cancellationToken = default)
+        {
+            try
+            {
+                var data = DeserializeNotification(msg);
+
+                messageReceiver.NewMessageRevicedTriger(data);
+                await DeleteMessageFromQueueAsync(amazonSQSClient, SQS_URL, msg.ReceiptHandle, cancellationToken);
+            }
+            catch (Exception ex)
+            {
+                messageReceiver.ErrorCatch(ex);
+                await DeleteMessageFromQueueAsync(amazonSQSClient, SQS_URL, msg.ReceiptHandle, cancellationToken);
+            }
+        }
         private async Task DeleteMessageFromQueueAsync(AmazonSQSClient sqsClient, string QueueUrl, string ReceiptHandle, CancellationToken cancellationToken = default)
         {
             var deleteMessageRequest = new DeleteMessageRequest() { QueueUrl = QueueUrl, ReceiptHandle = ReceiptHandle };