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);

Apache、ActiveMQ、Apache ActiveMQ、Apache 羽毛标志和 Apache ActiveMQ 项目标志是 Apache 软件基金会的商标。版权所有 © 2024,Apache 软件基金会。根据 Apache 许可证 2.0 授权。