Common/MessageQueue.cs

using System;
using System.Threading;
using System.Collections;

namespace Common
{
        public class MessageQueue : Queue
        {
                public MessageQueue() : base() {}
                
                public virtual Message DequeueBlocking() {
                        Message result;
                        lock (this) {
                                while (Count == 0) {
                                        Monitor.Wait(this);
                                }
                                result = (Message)Dequeue();
                                Monitor.Pulse(this);
                        }
                        return result;
                }

                public virtual void EnqueueBlocking(Message msg) {
                        lock(this) {
                                base.Enqueue(msg);
                                Monitor.Pulse(this);
                        }
                }
        }
}

---