从消息队列中删除定义数量的消息

Question

除了使用.Purge()，有没有办法从队列中删除定义数量的消息？

我尝试设置MessageEnumerator 并使用.RemoveCurrrent，在我对当前消息完成任何我需要做的事情后，但它似乎不起作用。

谢谢

public Message[] Get10(MessageQueue q)
    {

        int counter = 0;
        int mCount = 0;
        List<Message> ml = new List<Message>();
        try
        {
            MessageEnumerator me = q.GetMessageEnumerator2();
            while (me.MoveNext())
            {
                counter++;
            }
            if (counter > 10)
            {
                mCount = 10;
            }
            else
            {
                mCount = counter;
            }
            counter = 0;
            me.Reset();
            do
            {
                me.MoveNext();
                counter++;
                ml.Add(me.Current);
                me.RemoveCurrent();
            } while (counter < mCount);

        }

        catch (Exception x)
        {
            Console.WriteLine(x.Message);
        }
        Message[] m = ml.ToArray();
        return m;
    }

Answer 1

当您调用RemoveCurrent() 时，枚举器将移至下一条消息。在调用RemoveCurrent() 之后，您不必再调用MoveNext()。

您可以尝试的另一种方法如下：

    List<Message> ml = new List<Message>();
    int count = 0;

    while(  count < 10 ) {
        ml.Add(me.RemoveCurrent());
        ++count;
    }

在这种情况下，您必须注意，如果队列中没有消息，RemoveCurrent 将永远等待。如果这不是您想要的，您可能需要使用RemoveCurrent(TimeSpan timeout) 重载并捕获在超时情况下抛出的MessageQueueException。 MessageQueueException 类有一个 MessageQueueErrorCode 属性，如果超时已过期，则该属性设置为 MessageQueueErrorCode.IOTimeout。

或者（这将获得最多 10 条消息：如果队列中的消息计数降至零，则循环将退出）：

    List<Message> ml = new List<Message>();
    int count = 0;

    while( me.MoveNext() && count < 10 ) {
        ml.Add(queue.ReceiveById(me.Current.Id));
        ++count;
    }