#72 added SocketException reconnect retry

danzuep · Aug 10, 2024 · e881f9b · e881f9b
1 parent 087f638
commit e881f9b
Show file tree

Hide file tree

Showing 4 changed files with 88 additions and 64 deletions.
diff --git a/samples/WorkerServiceExample/EmailWorkerOptions.cs b/samples/WorkerServiceExample/EmailWorkerOptions.cs
@@ -1,10 +1,9 @@
-namespace MailKitSimplified.Sender.Models
+namespace ExampleNamespace;
+
+public class EmailWorkerOptions
 {
-    public class EmailWorkerOptions
-    {
-        public const string SectionName = "EmailWorker";
+    public const string SectionName = "EmailWorker";
 
-        public string DefaultFromAddress { get; set; } = "noreply@localhost";
-        public string DefaultToAddress { get; set; } = "noreply@localhost";
-    }
+    public string DefaultFromAddress { get; set; } = "noreply@localhost";
+    public string DefaultToAddress { get; set; } = "noreply@localhost";
 }
diff --git a/samples/WorkerServiceExample/Program.cs b/samples/WorkerServiceExample/Program.cs
@@ -1,11 +1,11 @@
 using MailKitSimplified.Sender;
 using MailKitSimplified.Receiver;
-using MailKitSimplified.Sender.Models;
+using ExampleNamespace;
 
-IHost host = Host.CreateDefaultBuilder(args)
+using var host = Host.CreateDefaultBuilder(args)
     .ConfigureServices((context, services) =>
     {
-        services.AddHostedService<ExampleNamespace.Worker>();
+        services.AddHostedService<Worker>();
         //services.AddMailKitSimplifiedEmail(context.Configuration);
         services.AddScopedMailKitSimplifiedEmailSender(context.Configuration);
         services.AddScopedMailKitSimplifiedEmailReceiver(context.Configuration);

diff --git a/samples/WorkerServiceExample/Worker.cs b/samples/WorkerServiceExample/Worker.cs
@@ -8,7 +8,6 @@
 using MailKitSimplified.Receiver.Extensions;
 using MailKitSimplified.Receiver.Services;
 using MailKitSimplified.Sender.Abstractions;
-using MailKitSimplified.Sender.Models;
 using Microsoft.Extensions.Options;
 
 namespace ExampleNamespace;
@@ -48,9 +47,9 @@ protected override async Task ExecuteAsync(CancellationToken cancellationToken =
         //await AddFlagsToNewestMessageSummaryAsync(cancellationToken);
         //await GetMailFolderCacheAsync();
         //await CreateFolderAndMoveTopOneAsync();
-        //await MonitorAsync(cancellationToken);
+        await MonitorAsync(cancellationToken);
         //await MoveToAsync(_processed, 1, cancellationToken);
-        await MonitorMoveAsync(cancellationToken);
+        //await MonitorMoveAsync(cancellationToken);
     }
 
     private static ImapReceiver CreateExchangeOAuth2ImapClientExample(SaslMechanismOAuth2 oauth2)
@@ -494,17 +493,16 @@ async Task ProcessMessageAsync(IMessageSummary messageSummary)
     private async Task MonitorAsync(CancellationToken cancellationToken = default)
     {
         using var smtpSender = _serviceScope.ServiceProvider.GetRequiredService<ISmtpSender>();
-        var sendTask = DelayedSendAsync(TimeSpan.FromMilliseconds(500), smtpSender, cancellationToken);
         void ProcessMessage(IMessageSummary messageSummary) =>
             _logger.LogInformation($"{_imapReceiver} message #{messageSummary.UniqueId} processed.");
+        var sendTask = DelayedSendAsync(TimeSpan.FromSeconds(3), smtpSender, cancellationToken);
         await _imapReceiver.MonitorFolder
             .SetMessageSummaryItems()
-            .SetIgnoreExistingMailOnConnect()
+            .SetIgnoreExistingMailOnConnect()   
             .OnMessageArrival(ProcessMessage)
             .OnMessageDeparture(ProcessMessage)
             .IdleAsync(cancellationToken);
         await sendTask;
-        _logger.LogInformation($"{_imapReceiver} Monitoring complete.");
     }
 
     public override void Dispose()