RetryableExcuteQueue

RetryableExcuteQueue

public class RetryableExcuteQueue<T>
        where T : CommonContract
    {
        private Queue<ExuteItem> queue;

        public RetryableExcuteQueue()
        {
            this.queue = new Queue<ExuteItem>();
        }

        public List<ExuteItem> ErrorItems { get; set; }

        public void Add(T o)
        {
            this.queue.Enqueue(new ExuteItem(o));
        }

        public void Add(List<T> o)
        {
            o.ForEach(x => this.queue.Enqueue(new ExuteItem(x)));
        }

        public void Excute(Action<T> action)
        {
            while (this.queue.Count > 0)
            {
                ExuteItem item = this.queue.Dequeue();
                try
                {
                    action(item.Value);
                }
                catch (HttpException ex)
                {
                    Log.Error(string.Format("Error Http Request: Product:{0},PlatformID:{1},Retry:{2}",
                        item.Value.ProductSysNo, item.Value.PlatformProductSysNo, item.Retry), ex);

                    if (item.Retry < 3)
                    {
                        item.Retry++;
                        this.queue.Enqueue(item);
                    }
                    else
                    {
                        if (this.ErrorItems == null)
                        {
                            this.ErrorItems = new List<ExuteItem>();
                        }
                        this.ErrorItems.Add(item);
                    }
                }
                catch (Exception ex)
                {
                    item.Error = ex;
                    if (this.ErrorItems == null)
                    {
                        this.ErrorItems = new List<ExuteItem>();
                    }
                    this.ErrorItems.Add(item);
                }
            }
        }

        public class ExuteItem
        {
            public ExuteItem(T value)
            {
                this.Value = value;
                this.Retry = 0;
            }

            public int Retry { get; set; }

            public T Value { get; set; }

            public Exception Error;
        }
    }