使用場景

在默認direct模式下, 多個消費者訂閱一個queue,消息會輪流發送至每個消費者。單一消費者模式下,消息只由一個消費者消費，除非該改消費者出現異常。由此可以保證消息消費的有序性。

使用示例

以下為java客戶端示例，通過在聲明隊列時配置x-single-active-consumer參數實現單一活躍消費者。

Map arguments = newHashMap();

arguments.put("x-single-active-consumer", true);

channel.queueDeclare("test_queue", false, false, false, arguments);