一、簡介

Queue中的消息是按照順序被分發到consumers的。然而，當你有多個consumers同時從相同的queue中提取消息時，

你將失去這個保證。因為這些消息是被多個線程並發的處理。有的時候，保證消息按照順序處理是很重要的。

如，你可能不希望在插入訂單操作結束之前執行更新這個訂單的操作。

二、使用

ActiveMQ從4.x版本起開始支持Exclusive Consumer。 Broker會從多個consumers中挑選一個consumer來處理queue中

所有的消息，從而保證了消息的有序處理。如果這個consumer失效，那麽broker會自動切換到其它的consumer。

可以通過DestinationOptions 來創建一個Exclusive Consumer，如下：

queue = new ActiveMQQueue("TEST.QUEUE?consumer.exclusive=true");
consumer = session.createConsumer(queue);

還可以給consumer設置優先級，以便針對網絡情況進行優化，如下：

queue = new ActiveMQQueue("TEST.QUEUE?consumer.exclusive=true&consumer.priority=10");

本文出自 “我愛大金子” 博客，請務必保留此出處http://1754966750.blog.51cto.com/7455444/1923595

ActiveMQ（19）：Consumer高級特性之獨有消費者（Exclusive Consumer）