الگوی Template Method

public abstract class Processor
{
    protected abstract void Process(string messageId, string message);

    public abstract bool Start(string msgId);

    protected void SendToQueue(string messageId, string message, string msgType)
    {
        _sender.SendToQueue(label, body, msgType);
    }

    protected void SaveToDb(string messageId, string msgType, string message, DateTime eventDateTime)
    {
        DbPersistor.Instance.Add(new RawMessage
        {
            MessageId = messageId,
            MessageType = msgType,
            MessageText = message,
            EventDateTime = eventDateTime,
            CreationDateTime = DateTime.Now
        });
    }
}

public abstract class StreamProcessor : Processor
{
    protected override void Process()
    {
        try
        {
           var messageResult = _connection.InitAsyncConnection(msgId);

            SaveToDb(messageResult.messageId, messageResult.msgType, messageResult.message,
                messageResult.eventDateTime);

            SendToQueue(messageResult.messageId, messageResult.message, messageResult.msgType);
        }
        catch (Exception ex)
        {
            Log4Repo.Critical("Exception in process message string", ex);
        }
    }
}

public abstract class FileProcessor : Processor
{
    protected override void Process()
    {
        try
        {
            using (var fileStream = new FileStream(filePath, FileMode.Open, FileAccess.Read))
            {
                using (var streamReader = new StreamReader(fileStream, Encoding.Default))
                {
                    string messageResult;

                    while (!_shouldStop && (messageResult = streamReader.ReadLine()) != null)
                    {
                        try
                        {
                            SaveToDb(messageResult.messageId, messageResult.msgType,
                                messageResult.message, messageResult.eventDateTime);

                            SendToQueue(messageResult.messageId, messageResult.message,
                                messageResult.msgType);
                        }
                        catch (Exception e)
                        {
                            Log4Repo.Critical(e);
                        }
                    }
                }
            }    
        }
        catch (Exception ex)
        {
            Log4Repo.Critical("Exception in process message string", ex);
        }
    }
}