How can I support priority queues?A common requirement is to support priority consumption; so high priority messages are consumed before low priority. Right now ActiveMQ doesn't automatically reorder messages on a queue based on their priority; which will harm performance as you have to leave messages hanging around a while to reorder them. You can implement priority based consumption using one of these techniques... Use SelectorsYou can have say 100 consumers using a selector to find the high priority stuff JMSPriority > 6 then have 50 consumers doing average or above JMSPriority >= 4 Then say 10 consumers consuming all messages (so all priorities). Then this way you'll have a pool of threads always processing high priority messages - giving you very efficient priority based dispatching of messages without ActiveMQ having to batch up messages and reorder them before dispatching them. Use ResequencerYou can reorder messages on some input queue A and send them to queue B in sorted order to avoid having to change your clients. This avoids the need to use selectors in your application as shown above. To do this use the Resequencer |
OverviewSearchSub ProjectsCommunity
Features
Connectivity
Using ActiveMQ 5
Using ActiveMQ 4
ToolsSupportRelated ProjectsDevelopersTests
Project Reports |