énumération des consommateurs ActiveMQ

Question

Est-il possible d'utiliser un consommateur ActiveMQ (.NET) comme ça?

foreach (var msg consommateur) {

// message de processus

}

de telle sorte que la boucle d'énumération arrête, sans consommer CPU, jusqu'à ce qu'un message est disponible? En effet, il serait une boucle infinie à moins que quelque chose ne va pas.

Answer 1

Vous pouvez effectuer une synchronisation pour obtenir quelque chose de consommer comme celui-ci avec une boucle while:

IMessage message = null;
while((message = consumer.Receive()) != null)
{
    //... process the message.
}

-Tim www.fusesource.com