Return-Path: X-Original-To: apmail-activemq-users-archive@www.apache.org Delivered-To: apmail-activemq-users-archive@www.apache.org Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by minotaur.apache.org (Postfix) with SMTP id 66F289F89 for ; Wed, 15 Feb 2012 20:59:12 +0000 (UTC) Received: (qmail 66617 invoked by uid 500); 15 Feb 2012 20:59:11 -0000 Delivered-To: apmail-activemq-users-archive@activemq.apache.org Received: (qmail 66577 invoked by uid 500); 15 Feb 2012 20:59:11 -0000 Mailing-List: contact users-help@activemq.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: users@activemq.apache.org Delivered-To: mailing list users@activemq.apache.org Received: (qmail 66569 invoked by uid 99); 15 Feb 2012 20:59:11 -0000 Received: from nike.apache.org (HELO nike.apache.org) (192.87.106.230) by apache.org (qpsmtpd/0.29) with ESMTP; Wed, 15 Feb 2012 20:59:11 +0000 X-ASF-Spam-Status: No, hits=1.5 required=5.0 tests=HTML_MESSAGE,RCVD_IN_DNSWL_LOW,SPF_PASS X-Spam-Check-By: apache.org Received-SPF: pass (nike.apache.org: domain of jelevy@gmail.com designates 209.85.220.171 as permitted sender) Received: from [209.85.220.171] (HELO mail-vx0-f171.google.com) (209.85.220.171) by apache.org (qpsmtpd/0.29) with ESMTP; Wed, 15 Feb 2012 20:59:03 +0000 Received: by vcbfo11 with SMTP id fo11so1484314vcb.2 for ; Wed, 15 Feb 2012 12:58:42 -0800 (PST) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=gmail.com; s=gamma; h=mime-version:from:date:message-id:subject:to:content-type; bh=jHb31nK8dg+31HxrcIXDSuJHdKlq3x7pI7qonU/M+eA=; b=YxH/xV8PAI2QK0jA7IdGxvLNZQg+yqBs5Et+K00fMgFvz0TMmv5ItC5UQ0jt+u9kms HCCc3OfnpfFgPbSTKbVysTq3lkUaA4d/9I3DVbGm8uScHnWcdH0vLpGkYQpJm7RT603A FNiZB3Q6H2wHf9rlaSrdshIj20WGUwP/xx3I0= Received: by 10.220.116.7 with SMTP id k7mr13842012vcq.62.1329339522844; Wed, 15 Feb 2012 12:58:42 -0800 (PST) MIME-Version: 1.0 Received: by 10.220.227.202 with HTTP; Wed, 15 Feb 2012 12:58:22 -0800 (PST) From: Jeremy Levy Date: Wed, 15 Feb 2012 15:58:22 -0500 Message-ID: Subject: JMS Priority To: users@activemq.apache.org Content-Type: multipart/alternative; boundary=f46d0438942b0b878a04b906fa07 X-Virus-Checked: Checked by ClamAV on apache.org --f46d0438942b0b878a04b906fa07 Content-Type: text/plain; charset=ISO-8859-1 I'm attempting to test JMS Priority with ActiveMQ 5.5.1 without much success and was hoping someone could point out something I am missing. My test case consists of putting 1000 messages on a queue with a priority (being set on both the producer and the message) of 0. Followed by putting 100 messages on the queue with a priority of 9. Then start the queue and print out the value of a TextMessage which also includes the priority in a String simply for debugging purposes. The result is that I see 1000 messages with the low priority followed by the 100 messages of high priority. Whereas I would assume I'd see the 100 high priority messages mixed it with the 1000 low priority rather then just being processed sequentially as they were added to the queue. The broker is a fresh install of ActiveMQ, I've only made the following configuration change in activemq.xml: ... ... When I create the queue, I'm using the following parameter "?consumer.prefetchSize=5", with the assumption that the prioritization happens in the broker, and a prefetched message will process once it's at the consumer regardless of prioritization. I based my configuration mainly on: http://activemq.apache.org/how-can-i-support-priority-queues.html Can anyone see what I am missing here? Jeremy --f46d0438942b0b878a04b906fa07--