NMS.ActiveMQ 目的地选项
背景
目的地选项是为 NMS 消费者提供扩展配置选项的一种方式,而无需扩展 NMS API。这些选项使用 URL 查询语法在消费者创建的目的地名称中进行编码。
消费者选项
选项名称 | 默认值 | 描述 |
---|---|---|
consumer.prefetchSize | 变量 | 消费者将预取的消息数量。NMS.ActiveMQ v1.7.0 中已移除,请使用 PrefetchPolicy 代替。 |
consumer.maximumPendingMessageLimit | 0 | 用于控制在存在慢速消费者情况时,是否丢弃非持久主题的消息。 |
consumer.noLocal | false | 与主题消费者上的 noLocal 标志相同。在这里公开,以便它可以与队列一起使用。 |
consumer.dispatchAsync | true | 代理是否应该异步地将消息分发给消费者。 |
consumer.retroactive | false | 这是否是一个追溯性消费者。 |
consumer.selector | null | 与消费者一起使用的 NMS 选择器。 |
consumer.exclusive | false | 这是否是一个独占消费者。 |
consumer.priority | 0 | 允许你配置一个消费者优先级。 |
示例
var queue = session.GetQueue("TEST.QUEUE?consumer.dispatchAsync=false&consumer.prefetchSize=10");
var consumer = session.CreateConsumer(queue);