Return-Path: Delivered-To: apmail-activemq-users-archive@www.apache.org Received: (qmail 2374 invoked from network); 5 Dec 2007 16:13:53 -0000 Received: from hermes.apache.org (HELO mail.apache.org) (140.211.11.2) by minotaur.apache.org with SMTP; 5 Dec 2007 16:13:53 -0000 Received: (qmail 81369 invoked by uid 500); 5 Dec 2007 16:13:41 -0000 Delivered-To: apmail-activemq-users-archive@activemq.apache.org Received: (qmail 81050 invoked by uid 500); 5 Dec 2007 16:13:40 -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 81041 invoked by uid 99); 5 Dec 2007 16:13:40 -0000 Received: from athena.apache.org (HELO athena.apache.org) (140.211.11.136) by apache.org (qpsmtpd/0.29) with ESMTP; Wed, 05 Dec 2007 08:13:40 -0800 X-ASF-Spam-Status: No, hits=-0.0 required=10.0 tests=SPF_PASS X-Spam-Check-By: apache.org Received-SPF: pass (athena.apache.org: domain of james.strachan@gmail.com designates 64.233.170.190 as permitted sender) Received: from [64.233.170.190] (HELO rn-out-0102.google.com) (64.233.170.190) by apache.org (qpsmtpd/0.29) with ESMTP; Wed, 05 Dec 2007 16:13:18 +0000 Received: by rn-out-0102.google.com with SMTP id e24so1347138rng for ; Wed, 05 Dec 2007 08:13:20 -0800 (PST) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=gmail.com; s=gamma; h=domainkey-signature:received:received:message-id:date:from:to:subject:in-reply-to:mime-version:content-type:content-transfer-encoding:content-disposition:references; bh=hdc4K+R8sM5hd8Y1b1D5jYXRpK6C3p8DizzYFrndVlA=; b=CovXF8vU9pUTR7xN+T7MpeaQ475EPDUkOUUdqXSYksCrNIZMLS1S7EqzdZ/5rLdgeQjOF3s0M3BNHAXQz/KSeLSTeZtGM842sXDokgMOTbTYfrPVJQfOO06y7Qor2+6PCu8SLJxbHYds+I6kfiWFqpJGpOSB7kLUvjGRKxk4ByM= DomainKey-Signature: a=rsa-sha1; c=nofws; d=gmail.com; s=gamma; h=received:message-id:date:from:to:subject:in-reply-to:mime-version:content-type:content-transfer-encoding:content-disposition:references; b=Fbcjx2qf0XvU5o+eRBLklYmHSHBYIa+xR8cRCLumedaZvwV/I35yaWmtrserqxt9gcNFSpg5Nf31kGwNdrMBcDkKEIa2C8A+M/lYU1EXJsNutcw4zTWDsX9v8F3oVMYdcFrEiiKTmfqWD7w3eudtfAN3um7/P01KUZw6wE68zGI= Received: by 10.151.12.1 with SMTP id p1mr828312ybi.1196871199861; Wed, 05 Dec 2007 08:13:19 -0800 (PST) Received: by 10.150.149.6 with HTTP; Wed, 5 Dec 2007 08:13:19 -0800 (PST) Message-ID: Date: Wed, 5 Dec 2007 16:13:19 +0000 From: "James Strachan" To: users@activemq.apache.org Subject: Re: Questions on Network of Brokers and high message rates In-Reply-To: <14174653.post@talk.nabble.com> MIME-Version: 1.0 Content-Type: text/plain; charset=ISO-8859-1 Content-Transfer-Encoding: 7bit Content-Disposition: inline References: <14145093.post@talk.nabble.com> <14161300.post@talk.nabble.com> <14165394.post@talk.nabble.com> <14173515.post@talk.nabble.com> <14174653.post@talk.nabble.com> X-Virus-Checked: Checked by ClamAV on apache.org On 05/12/2007, Marc Zampetti wrote: > James, > > Yes, it sounds like the JEDI thing and the partitioning approach is what I > need. And yes, I'm talking queues for the most part. For the partitioning, > is that something that AMQ, or are you talking about me having a layer in > front of AMQ that would do this. Its a pending feature request - basically a custom Transport inside ActiveMQ to do the partitioning. http://issues.apache.org/activemq/browse/AMQ-816 > In this case, instead of having one big > network of brokers, I would have several smaller networks of brokers? So a network of brokers is for store and forward; each subscription must be replicated across each broker so messages can be stored and forwarded from broker to broker. When talking about massive load, you generally don't wanna forward messages from one broker to another (as you're already overloading a single broker - you don't wanna send 2x or 3x the traffic due to store/forward). However you don't need that - what you need is producers partitioning (or just load balancing) across a number of brokers. i.e. its just a number of brokers thats all. Then ensuring that there are sufficient consumers connected to each broker. e.g. each one of your 50 producers could load balance across, day, 10 brokers. Then each 10 broker has a 100-5000 consumers processing requests concurrently (depending on how fast/slow it is to process messages). -- James ------- http://macstrac.blogspot.com/ Open Source Integration http://open.iona.com