Return-Path: Delivered-To: apmail-activemq-dev-archive@www.apache.org Received: (qmail 87870 invoked from network); 9 Jul 2009 20:05:19 -0000 Received: from hermes.apache.org (HELO mail.apache.org) (140.211.11.3) by minotaur.apache.org with SMTP; 9 Jul 2009 20:05:19 -0000 Received: (qmail 70960 invoked by uid 500); 9 Jul 2009 20:05:29 -0000 Delivered-To: apmail-activemq-dev-archive@activemq.apache.org Received: (qmail 70896 invoked by uid 500); 9 Jul 2009 20:05:29 -0000 Mailing-List: contact dev-help@activemq.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@activemq.apache.org Delivered-To: mailing list dev@activemq.apache.org Received: (qmail 70886 invoked by uid 99); 9 Jul 2009 20:05:29 -0000 Received: from athena.apache.org (HELO athena.apache.org) (140.211.11.136) by apache.org (qpsmtpd/0.29) with ESMTP; Thu, 09 Jul 2009 20:05:29 +0000 X-ASF-Spam-Status: No, hits=-2000.0 required=10.0 tests=ALL_TRUSTED X-Spam-Check-By: apache.org Received: from [140.211.11.140] (HELO brutus.apache.org) (140.211.11.140) by apache.org (qpsmtpd/0.29) with ESMTP; Thu, 09 Jul 2009 20:05:27 +0000 Received: from brutus (localhost [127.0.0.1]) by brutus.apache.org (Postfix) with ESMTP id 0147829A0011 for ; Thu, 9 Jul 2009 13:05:07 -0700 (PDT) Message-ID: <1624354678.1247169907001.JavaMail.jira@brutus> Date: Thu, 9 Jul 2009 13:05:07 -0700 (PDT) From: "ying (JIRA)" To: dev@activemq.apache.org Subject: [jira] Updated: (AMQ-2324) Forwarded message cannot be distributed to the original broker In-Reply-To: <948571663.1247169786992.JavaMail.jira@brutus> MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 7bit X-JIRA-FingerPrint: ae95407df07c98740808b2ef9da0087c X-Virus-Checked: Checked by ClamAV on apache.org [ https://issues.apache.org/activemq/browse/AMQ-2324?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ying updated AMQ-2324: ---------------------- Fix Version/s: 5.3.0 Affects Version/s: 5.2.0 > Forwarded message cannot be distributed to the original broker > -------------------------------------------------------------- > > Key: AMQ-2324 > URL: https://issues.apache.org/activemq/browse/AMQ-2324 > Project: ActiveMQ > Issue Type: Improvement > Affects Versions: 5.2.0 > Reporter: ying > Fix For: 5.3.0 > > > I have a simple cause which can cause dispatch problem: > 1. setup a network of broker1, broker2, bridged by multicast discovery > 2. make a producer send 5 msg to queueA to broker2 > 3. make a consumer to consume from broker1 queueA ( make it slow, so it only consumer 1 msg) but make sure all 5 msg from broker2 are forwared to broker1 > 4. stop the consumer to broke1, restart it to consume from broker2 queueA > 5. the 4 msgs originally published to broker2 and forwarded to broker1 and has not yet been consumed will stuck on broker1 and will not forwarded to broker2 for the consumer to consume. > Here is an solution: it checks forwarded to broker( eg, broker1) to see whether it has any active consumer, it will be able forward the message back to the original broker when there is no active consumer on the forwarded to broker. -- This message is automatically generated by JIRA. - You can reply to this email to add a comment to the issue online.