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 08CA810A9F for ; Tue, 1 Apr 2014 10:56:24 +0000 (UTC) Received: (qmail 69204 invoked by uid 500); 1 Apr 2014 10:56:15 -0000 Delivered-To: apmail-activemq-users-archive@activemq.apache.org Received: (qmail 68990 invoked by uid 500); 1 Apr 2014 10:56:01 -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 68475 invoked by uid 99); 1 Apr 2014 10:55:58 -0000 Received: from nike.apache.org (HELO nike.apache.org) (192.87.106.230) by apache.org (qpsmtpd/0.29) with ESMTP; Tue, 01 Apr 2014 10:55:58 +0000 X-ASF-Spam-Status: No, hits=-0.0 required=5.0 tests=RCVD_IN_DNSWL_NONE,SPF_PASS X-Spam-Check-By: apache.org Received-SPF: pass (nike.apache.org: domain of mikewse@hotmail.com designates 157.55.2.101 as permitted sender) Received: from [157.55.2.101] (HELO dub0-omc4-s26.dub0.hotmail.com) (157.55.2.101) by apache.org (qpsmtpd/0.29) with ESMTP; Tue, 01 Apr 2014 10:55:51 +0000 Received: from DUB128-DS11 ([157.55.2.73]) by dub0-omc4-s26.dub0.hotmail.com with Microsoft SMTPSVC(6.0.3790.4675); Tue, 1 Apr 2014 03:55:30 -0700 X-TMN: [uEBly0vvtJxXs5ZK7uz45CvbEi67X7LV] X-Originating-Email: [mikewse@hotmail.com] Message-ID: From: Mike Wilson To: Subject: queue dispatchpolicy based on "consumer load" Date: Tue, 1 Apr 2014 12:55:23 +0200 MIME-Version: 1.0 Content-Type: text/plain; charset="us-ascii" Content-Transfer-Encoding: 7bit X-Mailer: Microsoft Office Outlook 11 Thread-Index: Ac9NmOGbJyULNeUoRWqDzmn/gfdhHQ== X-MimeOLE: Produced By Microsoft MimeOLE V6.1.7601.17609 X-OriginalArrivalTime: 01 Apr 2014 10:55:30.0050 (UTC) FILETIME=[E5A99E20:01CF4D98] X-Virus-Checked: Checked by ClamAV on apache.org According to: http://activemq.apache.org/dispatch-policies.html queue load balancing use either the round-robin or "strict" method. Round-robin will give the same amount of work to consumers independent on if they are fast or slow, possibly leading to work building up on a slow consumer even when the other consumers are idle. Would it be possible to implement a queue dispatch policy that f ex prefers to dispatch to the consumer with the least number of unacknowledged messages, or maybe with the highest number of free prefetch slots? Or is the solution to use small enough prefetch values so that the maximum amount of queued work in any consumer is handled in a short time? Thanks Mike