【发布时间】:2011-03-07 21:49:19
【问题描述】:
是否可以像这样使用 activemq 消费者(在 .NET 中)?
foreach(消费者中的 var msg){
//处理消息
}
这样枚举循环会停止,而不消耗 CPU,直到有消息可用?实际上这将是一个无限循环,除非出现问题。
【问题讨论】:
是否可以像这样使用 activemq 消费者(在 .NET 中)?
foreach(消费者中的 var msg){
//处理消息
}
这样枚举循环会停止,而不消耗 CPU,直到有消息可用?实际上这将是一个无限循环,除非出现问题。
【问题讨论】:
您可以通过 while 循环执行同步消费来实现类似的效果:
IMessage message = null;
while((message = consumer.Receive()) != null)
{
//... process the message.
}
-Tim www.fusesource.com
【讨论】: