IncomingMessageQueue.cs

using System;
using System.Collections;
using GPRSWeb.SmartDeviceClient.Common;

namespace GPRSWeb.SmartDeviceClient.SmartProtocolStack
{
        public class IncomingMessageQueue : Common.MessageQueue {
                private StackInterface thisStack;

                public void ResetConnection() {
                        // TODO: Add any necessary code to IncomingMessageQueue.ResetConnection
                }

                public IncomingMessageQueue(StackInterface thisStack) {
                        this.thisStack = thisStack;
                }

                public void Enqueue(Message msg) {
                        if (msg.Type == MessageType.Retransmission) {
                                Segment seg = ((RetransmissionMessage)msg).RawSegment;
                                seg.IsRetransmission = true;
                                seg.Headers.TimeReceived = DateTime.Now;
                                thisStack.GetRemoteHostByID(seg.Headers.SourceDeviceID).AcceptIncomingSegment(seg);
                        } else {
                                lock(SyncRoot) {
                                        base.Enqueue(msg);
                                        Monitor.PulseAll(SyncRoot);
                                }
                        }
                }
        }
}

---