Return-Path: Delivered-To: apmail-activemq-users-archive@www.apache.org Received: (qmail 48430 invoked from network); 10 Jul 2008 16:01:34 -0000 Received: from hermes.apache.org (HELO mail.apache.org) (140.211.11.2) by minotaur.apache.org with SMTP; 10 Jul 2008 16:01:34 -0000 Received: (qmail 4087 invoked by uid 500); 10 Jul 2008 16:01:33 -0000 Delivered-To: apmail-activemq-users-archive@activemq.apache.org Received: (qmail 4066 invoked by uid 500); 10 Jul 2008 16:01:33 -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 4055 invoked by uid 99); 10 Jul 2008 16:01:33 -0000 Received: from athena.apache.org (HELO athena.apache.org) (140.211.11.136) by apache.org (qpsmtpd/0.29) with ESMTP; Thu, 10 Jul 2008 09:01:33 -0700 X-ASF-Spam-Status: No, hits=2.6 required=10.0 tests=DNS_FROM_OPENWHOIS,SPF_HELO_PASS,SPF_PASS,WHOIS_MYPRIVREG X-Spam-Check-By: apache.org Received-SPF: pass (athena.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; Thu, 10 Jul 2008 16:00:40 +0000 Received: from isper.nabble.com ([192.168.236.156]) by kuber.nabble.com with esmtp (Exim 4.63) (envelope-from ) id 1KGyZq-0004gI-Tw for users@activemq.apache.org; Thu, 10 Jul 2008 09:01:02 -0700 Message-ID: <18385580.post@talk.nabble.com> Date: Thu, 10 Jul 2008 09:01:02 -0700 (PDT) From: "Bryan.Shaw" To: users@activemq.apache.org Subject: Re: Help needed. About message loss in distributed queue in network of brokers environment In-Reply-To: <6624A83C-A835-43B0-9D0C-A12F18DC5687@gmail.com> MIME-Version: 1.0 Content-Type: text/plain; charset=us-ascii Content-Transfer-Encoding: 7bit X-Nabble-From: bryan@erry.com References: <18377630.post@talk.nabble.com> <18378847.post@talk.nabble.com> <18379174.post@talk.nabble.com> <6624A83C-A835-43B0-9D0C-A12F18DC5687@gmail.com> X-Virus-Checked: Checked by ClamAV on apache.org I am not using async send from the client. But, I am using duplex connection because one of the two brokers do not have fixed IP Address. How can I avoid using duplex connnection if only one IP is fixed? rajdavies wrote: > > This is currently only the case if you are using duplex connections - > or the message was originally sent using async send from the client > (e.g. non-persistent) - as the network tries to maintain the same QOS > as used by the original producer > > cheers, > > Rob > > On 10 Jul 2008, at 10:34, Bryan.Shaw wrote: > >> >> It is sad that the activemq message sending is default to sync send. >> So this issue is still open. >> >> Please provide help! >> >> >> Bryan.Shaw wrote: >>> >>> I discovered that the message transfer between network of brokers is >>> handled by DemandForwardingBridgeSupport class and there is some >>> comment >>> on async send mode will be assumed between brokers if the producer >>> send >>> the message to the queue using async send mode which will cause small >>> probability of message loss. >>> >>> I am now testing the sync send mode on the producer side, hope this >>> can >>> resolve my problem. >>> >>> >>> Bryan.Shaw wrote: >>>> >>>> We have a distributed architecture with two brokers connnected to >>>> each >>>> other through WAN. >>>> >>>> We configured it using network of brokers. >>>> One producer sends messages to a distributed queue named "aqueue" on >>>> broker A. >>>> One consumer consume messages from the queue "aqueue" on broker B. >>>> >>>> I thought activemq is responsible for the reliability of the message >>>> transfer. >>>> Which means the when message are sent to aqueue at broker A, the >>>> messages >>>> are first store on broker A's persistent store and then forwarded to >>>> broker B's persistent store and afterwards consumed by the >>>> consumer on >>>> broker B. If network between these two brokers are not stable, it is >>>> activemq's job to ensure the message is delivered and delivered only >>>> once. >>>> >>>> But in real production environment, we found message loss when >>>> network >>>> between the two brokers is down. >>>> >>>> I need proffesional help to address this issue. Is this a bug of >>>> activemq >>>> or a configuration issue? >>>> Can anybody give me some advice to avoid this kind of message loss? >>>> >>> >>> >> >> -- >> View this message in context: >> http://www.nabble.com/Help-needed.-About-message-loss-in-distributed-queue-in-network-of-brokers-environment-tp18377630p18379174.html >> Sent from the ActiveMQ - User mailing list archive at Nabble.com. >> > > > -- View this message in context: http://www.nabble.com/Help-needed.-About-message-loss-in-distributed-queue-in-network-of-brokers-environment-tp18377630p18385580.html Sent from the ActiveMQ - User mailing list archive at Nabble.com.