From users-return-28182-apmail-activemq-users-archive=activemq.apache.org@activemq.apache.org Wed Jul 13 07:31:48 2011 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 CBEC64567 for ; Wed, 13 Jul 2011 07:31:48 +0000 (UTC) Received: (qmail 11782 invoked by uid 500); 13 Jul 2011 07:31:46 -0000 Delivered-To: apmail-activemq-users-archive@activemq.apache.org Received: (qmail 11196 invoked by uid 500); 13 Jul 2011 07:31:30 -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 11160 invoked by uid 99); 13 Jul 2011 07:31:25 -0000 Received: from athena.apache.org (HELO athena.apache.org) (140.211.11.136) by apache.org (qpsmtpd/0.29) with ESMTP; Wed, 13 Jul 2011 07:31:25 +0000 X-ASF-Spam-Status: No, hits=1.5 required=5.0 tests=FREEMAIL_FROM,HTML_MESSAGE,RCVD_IN_DNSWL_LOW,SPF_PASS,T_TO_NO_BRKTS_FREEMAIL X-Spam-Check-By: apache.org Received-SPF: pass (athena.apache.org: domain of chubrilo@gmail.com designates 209.85.161.41 as permitted sender) Received: from [209.85.161.41] (HELO mail-fx0-f41.google.com) (209.85.161.41) by apache.org (qpsmtpd/0.29) with ESMTP; Wed, 13 Jul 2011 07:31:19 +0000 Received: by fxg9 with SMTP id 9so5130261fxg.28 for ; Wed, 13 Jul 2011 00:30:57 -0700 (PDT) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=gmail.com; s=gamma; h=mime-version:sender:in-reply-to:references:date :x-google-sender-auth:message-id:subject:from:to:content-type; bh=Xk6H06ldxD8SjXpcUHfKpW/B9Y4eYhB9hu3hlotOJGc=; b=iC2wWS/Ijc/IHVYN+HaAIa55xffTY5bckit/exozj9BTwrGPztRe2rJcG0SJcOKfj+ y59H25ybOm497arTW8RFHQfZfM7nQ4XofY02B10yEDuGtGmJRa5Fdw0wMAbC2M5rHRSX zDEs7KNLQOelmY/gy+7JDbhhPQvlEVM3LKMGI= MIME-Version: 1.0 Received: by 10.223.91.75 with SMTP id l11mr1248168fam.66.1310542257395; Wed, 13 Jul 2011 00:30:57 -0700 (PDT) Sender: chubrilo@gmail.com Received: by 10.223.96.8 with HTTP; Wed, 13 Jul 2011 00:30:57 -0700 (PDT) In-Reply-To: References: Date: Wed, 13 Jul 2011 09:30:57 +0200 X-Google-Sender-Auth: Ux6fQThmkDkATSmHkkvbE1m4lls Message-ID: Subject: Re: topic message distribution From: Dejan Bosanac To: users@activemq.apache.org Content-Type: multipart/alternative; boundary=001517478f32b7194304a7ee65bf --001517478f32b7194304a7ee65bf Content-Type: text/plain; charset=ISO-8859-1 Hi Mark, the message by default is sent in serial order to all available subscribers. It can be changed by implementing appropriate DispatchPolicy https://fisheye6.atlassian.com/browse/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/DispatchPolicy.java?hb=true and configuring it later to be used for certain topic(s) ( http://activemq.apache.org/dispatch-policies.html) Regards -- Dejan Bosanac - http://twitter.com/dejanb ----------------- The experts in open source integration and messaging - http://fusesource.com ActiveMQ in Action - http://www.manning.com/snyder/ Blog - http://www.nighttale.net On Tue, Jul 12, 2011 at 8:56 PM, Mark Greene wrote: > With AMQ topics, when a message is published and there are multiple > subscribers to the topic, is the message pushed in a serial order or in > parallel to subscribers? > > If it's in parallel, does AMQ create a separate thread per topic > subscriber? > > Thanks in advance, > Mark > --001517478f32b7194304a7ee65bf--