Как я могу регулировать количество сообщений, приходящих от ActiveMQ в моем приложении C #?

Я использую ActiveMQ в файле. Net, и меня засыпают сообщениями-событиями.

Короче говоря, когда я получаю событие очереди 'onMessage (IMessage receiveMsg)', я помещаю сообщение во внутреннюю очередь, из которой X-потоки делают свое дело.

] Сначала у меня было: 'AcknowledgementMode.AutoAcknowledge' при создании сеанса, поэтому я предполагаю, что все сообщения в очереди были засосаны и помещены в очередь памяти (что рискованно, поскольку при сбое все теряется).

Затем я использовал: 'AcknowledgementMode.ClientAcknowledge' при создании сеанса, и когда рабочий был готов с сообщением, он вызывает метод 'commit ()' сообщения. Однако все сообщения по-прежнему высасываются из очереди.

Как я могу настроить его, чтобы ТОЛЬКО X сообщений обрабатывались или находились во внутренней очереди, и что не все сразу «загружается»?

5
задан Toad 25 November 2010 в 13:46
поделиться