Return-Path: 
 <dev-return-7483-apmail-activemq-dev-archive=activemq.apache.org@activemq.apache.org>
Delivered-To: apmail-activemq-dev-archive@www.apache.org
Received: (qmail 36259 invoked from network); 16 Jul 2007 08:56:12 -0000
Received: from hermes.apache.org (HELO mail.apache.org) (140.211.11.2)
  by minotaur.apache.org with SMTP; 16 Jul 2007 08:56:12 -0000
Received: (qmail 50502 invoked by uid 500); 16 Jul 2007 08:56:13 -0000
Delivered-To: apmail-activemq-dev-archive@activemq.apache.org
Received: (qmail 50207 invoked by uid 500); 16 Jul 2007 08:56:12 -0000
Mailing-List: contact dev-help@activemq.apache.org; run by ezmlm
Precedence: bulk
List-Help: <mailto:dev-help@activemq.apache.org>
List-Unsubscribe: <mailto:dev-unsubscribe@activemq.apache.org>
List-Post: <mailto:dev@activemq.apache.org>
List-Id: <dev.activemq.apache.org>
Reply-To: dev@activemq.apache.org
Delivered-To: mailing list dev@activemq.apache.org
Received: (qmail 50198 invoked by uid 99); 16 Jul 2007 08:56:12 -0000
Received: from herse.apache.org (HELO herse.apache.org) (140.211.11.133)
    by apache.org (qpsmtpd/0.29) with ESMTP; Mon, 16 Jul 2007 01:56:12 -0700
X-ASF-Spam-Status: No, hits=-0.0 required=10.0
	tests=SPF_HELO_PASS,SPF_PASS
X-Spam-Check-By: apache.org
Received-SPF: pass (herse.apache.org: domain of lists@nabble.com designates
 216.139.236.158 as permitted sender)
Received: from [216.139.236.158] (HELO kuber.nabble.com) (216.139.236.158)
    by apache.org (qpsmtpd/0.29) with ESMTP; Mon, 16 Jul 2007 01:56:09 -0700
Received: from isper.nabble.com ([192.168.236.156])
	by kuber.nabble.com with esmtp (Exim 4.63)
	(envelope-from <lists@nabble.com>)
	id 1IAMMu-00014B-Ca
	for dev@activemq.apache.org; Mon, 16 Jul 2007 01:55:48 -0700
Message-ID: <11611341.post@talk.nabble.com>
Date: Mon, 16 Jul 2007 01:55:48 -0700 (PDT)
From: Elber <shaheer@hotmail.fr>
To: dev@activemq.apache.org
Subject: Can't find differences between DispatchPolicies
MIME-Version: 1.0
Content-Type: text/plain; charset=us-ascii
Content-Transfer-Encoding: 7bit
X-Nabble-From: shaheer@hotmail.fr
X-Virus-Checked: Checked by ClamAV on apache.org


Hi,

I'm trying the diiferent Dispatch Policies but the dispatching way is the
same.
I have 5 threads which contain one slow consumer (sleep).
My destinationPlicy is as the following:

<destinationPolicy>
      <policyMap>
        <policyEntries>
          <policyEntry>
           <destination>
                <queue physicalName="myqueue" />
            </destination>
            <dispatchPolicy>
               <roundRobinDispatchPolicy />
            </dispatchPolicy>
          </policyEntry>
        </policyEntries>
      </policyMap>
      <oldestMessageEvictionStrategy/>
    </destinationPolicy>

when I send 10000 messages, 3 threads receive 2000 messages, 1 thread
receives 2999 messages, and the slow consumer 1 message/10 s.
when I stop the receivers and restart them, one thread consumes the rest of
messages not consumed.

If I change the dispatchPolicy to strictOrderDispatchPolicy, the same
scenario will be repeated.

* I want to know if there is a solution to force other threads to consume
the messages of the slowest directly without the need to stop and restart
them(access to messages of the slowest's RAM). 

* I'm not able to apply oldestMessageEvictionStrategy.

Thank you for your help.
-- 
View this message in context: http://www.nabble.com/Can%27t-find-differences-between-DispatchPolicies-tf4085262s2354.html#a11611341
Sent from the ActiveMQ - Dev mailing list archive at Nabble.com.