NMS.ActiveMQ 消費者優先權

背景

除了具有可插拔的調度策略(例如,循環配置等)之外,我們現在支援消費者優先權。

這使我們可以權衡消費者以優化網路跳躍次數。例如,您通常希望訊息代理程式將訊息發送到常規的 NMS 消費者,而不是其他訊息代理程式;如果存在可用的消費者,則無需進行不必要的訊息代理程式到訊息代理程式的跳躍。

範例

消費者的優先權是使用 目的地選項 進行設定,如下所示

var queue = session.GetQueue("TEST.QUEUE?consumer.priority=10");
var consumer = session.CreateConsumer(queue);

分配優先權的範圍是從 0 到 127,其中 127 是最高優先權,而 0 是預設優先權。
其運作方式是,訊息代理程式將簡單地根據其優先權對任何佇列消費者進行排序,並首先將訊息發送到最高優先權的消費者。
一旦特定消費者的預取緩衝區被填滿,訊息代理程式將開始將訊息調度到較低優先權的消費者。

Apache、ActiveMQ、Apache ActiveMQ、Apache 羽毛標誌和 Apache ActiveMQ 項目標誌是 Apache 軟體基金會的商標。版權 © 2024,Apache 軟體基金會。依據 Apache License 2.0 授權。