Длинные цепочки операций. Организация кода

(автосгенерированный код опущен)
using System.ComponentModel;
using System.Diagnostics;
using System.ServiceProcess;
 
namespace Lanit.OOSMonitoring.MonitoringIntegrator.IntegrationService
{
    public partial class IntegrationService : ServiceBase
    {
        private readonly EmailProcessor _emailProcessor;
 
        public IntegrationService()
        {
            InitializeComponent();
            _emailProcessor = new EmailProcessor(AddLog);
        }
 
        protected override void OnStart(string[] args)
        {
            AddLog("Starting...");
            var bw = new BackgroundWorker();                                // Создали воркера
            bw.DoWork += (sender, eventArgs) => _emailProcessor.OnElapsed();  // чтобы он запустио одну итерацию проверки почты
            bw.RunWorkerCompleted += (sender, eventArgs) => _emailProcessor.SendTimer.Start(); //Когда закончит, включает таймер, чтобы он дальше постоянно занимался тем же
            bw.RunWorkerAsync();
            AddLog("Started");
        }
 
        protected override void OnStop()
        {
            _emailProcessor.SendTimer.Stop();
            AddLog("Stopped");
        }
        
        private static void AddLog(string log, EventLogEntryType type = EventLogEntryType.SuccessAudit)
        {
            if (!EventLog.SourceExists("OOSIntegrationService"))
            {
                EventLog.CreateEventSource("OOSIntegrationService", "OOSIntegrationService");
            }
            eventLog.Source = "OOSIntegrationService";
            eventLog.WriteEntry(log, type);
        }
    }
}

using System;
using System.Diagnostics;
using System.IO;
using System.Net.Mail;
using System.Reflection;
using System.Text.RegularExpressions;
using System.Timers;
using Lanit.OOSMonitoring.MonitoringIntegrator.Integration;
using Lanit.OOSMonitoring.MonitoringIntegrator.Integration.Importers;
using OpenPop.Mime;
using OpenPop.Pop3;
using OpenPop.Pop3.Exceptions;
 
namespace Lanit.OOSMonitoring.MonitoringIntegrator.IntegrationService
{
    public class EmailProcessor
    {
        private readonly Action<string, EventLogEntryType> _logger;
        private readonly Action<string> _sucessLogger;
        
        private const string SubjectMask = "Письмо: <{0}>, отправлено с адреса: {1}, содержание: {2}";
        private static readonly string Outlining = new string('_', 40);
        private static readonly string StartupPath;
        public readonly Timer SendTimer;
 
        static EmailProcessor()
        {
            Assembly entryAssembly = Assembly.GetEntryAssembly();
            StartupPath = entryAssembly != null
                              ? Path.GetDirectoryName(entryAssembly.Location)
                              : Directory.GetCurrentDirectory();
        }
 
        private static string LogPath
        {
            get
            {
                return Path.Combine(StartupPath, "Monitoring") +
                       DateTime.Now.Date.ToShortDateString() + ".logoos";
            }
        }
 
 
        /// <summary>
        /// Конструктор, в качестве параметра принимает коллбек-делегат для логгирования
        /// </summary>
        /// <param name="logger">делегат, вызываемый для ведения логов</param>
        public EmailProcessor(Action<string, EventLogEntryType> logger)
        {
            _logger = logger;
            _sucessLogger = s => logger(s, EventLogEntryType.SuccessAudit);
            SendTimer = new Timer(Configuration.MinutesToRefresh * 60 * 1000.0);
            SendTimer.Elapsed += (sender, args) => OnElapsed();
            EmailParser.SubjectRegex = Configuration.SubjectRegex;
        }
 
 
        /// <summary>
        /// Конструктор для создания чекера, который не ведет логов
        /// </summary>
        public EmailProcessor()
            : this((s, type) => { })
        {
 
        }
 
        /// <summary>
        /// Функция, которая вызывается по таймеру и вызовом обработки сообщений, а также логгированием
        /// </summary>
        public void OnElapsed()
        {
            try
            {
                _sucessLogger("Sending messages");
                ProcessMailMessages();
            }
 
            catch (PopServerNotFoundException ex)
            {
                const string format =
                    "Exception = {0}, Message = {1}, InnerException = {2}, Source = {3}, Data = {4}, PopHostName = {5}, Port = {6}, UseSSL = {7}";
                _logger(
                    string.Format(format, ex, ex.Message, ex.InnerException, ex.Source, ex.Data,
                                  Configuration.PopHostName,
                                  Configuration.Port, Configuration.UseSSL), EventLogEntryType.Error);
                throw;
            }
 
            catch (Exception ex)
            {
                _logger(GetExceptionLogString(ex), EventLogEntryType.Error);
            }
 
            _sucessLogger(string.Format("All messages are processed. Sleeping for {0} minutes",
                                        Configuration.MinutesToRefresh));
        }
 
        /// <summary>
        /// Логинится на ящик и начинает обработку имеющихся на нем сообщений
        /// </summary>
        public void ProcessMailMessages()
        {
            using (var fileLogger = new StreamWriter(LogPath, true))
            {
                fileLogger.WriteLine("Начинаю обработку, время = {0}", DateTime.Now.ToShortTimeString());
                Pop3Client client = null;
                int i = 0;
 
 
                fileLogger.WriteLine("Пытаюсь залогиниться на pop3");
                try
                {
                    client = new Pop3InitializableClient();
                    fileLogger.WriteLine("Начинаю обработку писем");
                    foreach (var message in client.GetMessages())
                    {
                        i++;
                        const string mask = "Обрабатываю письмо №{0}, заголовок {1}, отправлено от <{2}>, дата: {3}";
                        fileLogger.WriteLine(mask, i, message.Headers.Subject, message.Headers.From.Address,
                                     message.Headers.DateSent);
                        //TODO: добавить проверку отправителя (письмо должно приходить только с конкретного ящика)
 
                            EventRecord record;
                            if (!message.TryConvertToEventRecord(out record))
                            {
                                fileLogger.WriteLine("Тема письма не удовлетворяет регулярному выражению");
                                OnException(message, "Тема письма не удовлетворяет регулярному выражению");
                            }
                            else if (ImporterFactory.GetImporter(record.ComponentID).Contains(record))
                            {
                                fileLogger.WriteLine("В базе уже существует запись события с таким ID:\t{0}", record);
                                OnException(message, "В базе уже существует запись события с таким ID");
                            }
                            else
                            {
                                fileLogger.WriteLine("Письмо в порядке, пытаюсь добавить в базу");
                                ImportToDb(record);
                                fileLogger.WriteLine("Письмо добавлено{0}", Environment.NewLine);
                            }
                        }
 
                        client.DeleteMessage(i);
                    }
                }
 
                catch (PopClientException ex)
                {
                    fileLogger.WriteLine(GetExceptionLogString(ex));
                    _logger(GetExceptionLogString(ex), EventLogEntryType.Warning);
                }
 
                finally
                {
                    if (client != null)
                        client.Dispose();
                    if (i == 0)
                        fileLogger.WriteLine("Писем на ящике не обнаружено");
                    else
                        fileLogger.WriteLine("Обработано {0} писем", i);
                }
 
                fileLogger.WriteLine(Outlining);
            }
        }
 
        private static string GetExceptionLogString(Exception ex)
        {
            return string.Format("Some error has occurred :{0}\t{1}\t{2}\t{3}", ex.Message, ex.Data, ex.Source,
                                 ex.StackTrace);
        }
 
        /// <summary>
        /// Удаление тегов
        /// </summary>
        /// <param name="html"></param>
        /// <returns></returns>
        private static string RemoveHtmlTags(string html)
        {
            string result = Regex.Replace(html, @"<br\s*/?>", Environment.NewLine, RegexOptions.IgnoreCase);
            return Regex.Replace(result, "<.+?>", string.Empty);
        }
 
        private static void ImportToDb(EventRecord record)
        {
            var parsedEvents = record.Split();
            var importer = ImporterFactory.GetImporter(record.ComponentID);
            foreach (EventRecord e in parsedEvents)
                importer.AddToDB(e);
        }
 
        private static void OnException(Message message, string comment)
        {
            var mail = message.ToMailMessage();
 
 
            string oldsubject = mail.Subject;
            mail.Subject = comment;
 
            using (var smtpClient = Configuration.DefaultSmtpClient)
            {
                string subject = mail.Subject;
                string body = string.Format(SubjectMask, oldsubject, mail.From.Address, RemoveHtmlTags(mail.Body));
 
                smtpClient.Send(Configuration.MailAdress, Configuration.Recepients, subject, body);
            }
        }
    }
}