ELK/FrameworkLocal/Common/Log/LogManager.cs

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using Aitex.Core.Util;
using log4net.Core;
using System.Diagnostics;

namespace Aitex.Core.RT.Log
{
    public class LogManager : ICommonLog
    {
        PeriodicJob _loggingJob;
        FixSizeQueue<LogItem> _logQueue;
        LogWriter _writer;

        public LogManager()
        {

        }

        public void Initialize()
        {
            _logQueue = new FixSizeQueue<LogItem>(1000);
            _loggingJob = new PeriodicJob(300, this.PeriodicRun, "Save Log Job", true);
            _writer = new LogWriter();

            LOG.InnerLogger = this;
        }

        public void Terminate()
        {
            try
            {
                if (_loggingJob != null)
                {
                    _loggingJob.Stop();
                    _loggingJob = null;
                }
            }
            catch (Exception ex)
            {
                System.Diagnostics.Trace.WriteLine(ex.Message);
            }
        }

        public void Info(string message, bool isTraceOn, string stackFile)
        {
            CacheLog(message, Level.Info, null, isTraceOn, stackFile);
        }

        public void Warning(string message, string stackFile)
        {
            CacheLog(message, Level.Warn, null, true, stackFile);
        }

        public void Error(string message, string stackFile)
        {
            CacheLog(message, Level.Error, null, true, stackFile);
        }

        public void Warning(string message, Exception ex, string stackFile)
        {
            CacheLog(message, Level.Warn, ex, true, stackFile);
        }

        public void Error(string message, Exception ex, string stackFile)
        {
            CacheLog(message, Level.Error, ex, true, stackFile);
        }


        bool PeriodicRun()
        {
            LogItem item;
            while (_logQueue.TryDequeue(out item))
            {
                
                string log = _writer.Write(item);

            }

            return true;
        }

        void CacheLog(string message, Level level, Exception exception, bool isTraceOn, string stackFile)
        {
            //if (isTraceOn)
            //{
            //    System.Diagnostics.Trace.WriteLine(message + (exception == null ? "" : exception.Message));
            //}

            _logQueue.Enqueue(new LogItem(message, new StackTrace(true).GetFrame(5), level, exception, stackFile));
        }
    }
}