From users-return-29579-apmail-activemq-users-archive=activemq.apache.org@activemq.apache.org Wed Dec 7 09:05:02 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 88F8E7773 for ; Wed, 7 Dec 2011 09:05:02 +0000 (UTC) Received: (qmail 25306 invoked by uid 500); 7 Dec 2011 09:05:01 -0000 Delivered-To: apmail-activemq-users-archive@activemq.apache.org Received: (qmail 24947 invoked by uid 500); 7 Dec 2011 09:04:37 -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 24901 invoked by uid 99); 7 Dec 2011 09:04:28 -0000 Received: from nike.apache.org (HELO nike.apache.org) (192.87.106.230) by apache.org (qpsmtpd/0.29) with ESMTP; Wed, 07 Dec 2011 09:04:28 +0000 X-ASF-Spam-Status: No, hits=2.2 required=5.0 tests=HTML_MESSAGE,SPF_PASS X-Spam-Check-By: apache.org Received-SPF: pass (nike.apache.org: domain of suonayi2006@163.com designates 220.181.13.34 as permitted sender) Received: from [220.181.13.34] (HELO m13-34.163.com) (220.181.13.34) by apache.org (qpsmtpd/0.29) with ESMTP; Wed, 07 Dec 2011 09:04:20 +0000 DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=163.com; s=s110527; h=Received:Date:From:To:Message-ID:In-Reply-To: References:Subject:MIME-Version:Content-Type; bh=Ltopd9mIwUogZi9 dBsAD+NojpiKToLP4N+A95k6so0Q=; b=V/4rwpjbS3eZcjqOpU7Mxk48VNztPRC sxRPGt+GSCB3fcWktnZR+9+iYzaAskXGyRfclhR+cb+f9AMnhas5DoWoJtGtVeFY VAk+ciFMGvUstWlhv/dDvL4DXAiOFA87a8ELKo+1eaUT42ZG8tV0W/i5+fPcCf71 N2yk2NL6xLrg= Received: from suonayi2006 ( [203.119.80.8] ) by ajax-webmail-wmsvr34 (Coremail) ; Wed, 7 Dec 2011 17:03:49 +0800 (CST) Date: Wed, 7 Dec 2011 17:03:49 +0800 (CST) From: SuoNayi To: users@activemq.apache.org Message-ID: <2180e2ae.ae7b.13417c3b788.Coremail.suonayi2006@163.com> In-Reply-To: <180c58d5.5db0.13416cefd3b.Coremail.suonayi2006@163.com> References: <180c58d5.5db0.13416cefd3b.Coremail.suonayi2006@163.com> <79C3D85C-46CD-4D80-A7DC-1B3DA6C8C0C5@fusesource.com> <0254D7CB-40DC-4B6C-B540-49E0D6B7977C@fusesource.com> <121e9285.17c30.13411f02379.Coremail.suonayi2006@163.com> <5a0a5989.1ddca.13413d42488.Coremail.suonayi2006@163.com> <6359e013.292cd.134141d1513.Coremail.suonayi2006@163.com> Subject: Reply:Reply:Re: Reply:Re: Reply:Re: Is there a simple way to solve the issuse of stuck messages when network? MIME-Version: 1.0 Content-Type: multipart/alternative; boundary="----=_Part_136763_871377236.1323248629640" X-Originating-IP: [203.119.80.8] X-Priority: 3 X-Mailer: Coremail Webmail Server Version SP_ntes V3.5 build 111110(15680.4167.4075) Copyright (c) 2002-2011 www.mailtech.cn 163com X-CM-CTRLDATA: x3p4SWZvb3Rlcl9odG09MjE4MTU6ODE= X-CM-TRANSID:IsGowGAp0UL2K99O+zYRAA--.16571W X-CM-SenderInfo: xvxr0td1lsiiqw6rljoofrz/1tbiFgEPGj-6bY0Z+wAAsF X-Coremail-Antispam: 1U5529EdanIXcx71UUUUU7vcSsGvfC2KfnxnUU== X-Virus-Checked: Checked by ClamAV on apache.org ------=_Part_136763_871377236.1323248629640 Content-Type: text/plain; charset=GBK Content-Transfer-Encoding: 7bit Another confusion abount forwarding messages and back. The lastest release version such as apache-activemq-5.5.1-fuse-01-06 and apache-activemq-5.5.1-fuse-01-11 has added a new conditionalNetworkBridgeFilter to allow messages to be forwarded back to the original broker where it come from. while in the forward process,forward bridge does not set new messageId for the message. Duplicate audit will be applied when the message comes back from the remote broker and it will be recognized to be duplicate message and suppressed, won't it? Counld someone make me clear? Thanks. At 2011-12-07 12:36:31,SuoNayi wrote: >I have tested apache-activemq-5.5.1-fuse-01-06 and apache-activemq-5.5.1-fuse-01-11 and they don't work as well. >I'm depressed so much after lots of tests. >My configuration files are the following: >------------------------------------------------------------------------------------------------------------------------------------------------------------------------ > xmlns="http://www.springframework.org/schema/beans" > xmlns:amq="http://activemq.apache.org/schema/core" > xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" > xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-2.0.xsd > http://activemq.apache.org/schema/core http://activemq.apache.org/schema/core/activemq-core.xsd"> > > > > > > > > > > > > > > > > > > > > > > > > > name="nc1" > duplex="true" > networkTTL="6" > dynamicOnly="true" > prefetchSize="1" > conduitSubscriptions="true" > suppressDuplicateQueueSubscriptions="true" > suppressDuplicateTopicSubscriptions="true" > decreaseNetworkConsumerPriority="true" /> > > > > > > > > > > > > > > > > > > > > > > > > > > > > >------------------------------------------------------------------------------------------------------------------------------------------------------ > xmlns="http://www.springframework.org/schema/beans" > xmlns:amq="http://activemq.apache.org/schema/core" > xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" > xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-2.0.xsd > http://activemq.apache.org/schema/core http://activemq.apache.org/schema/core/activemq-core.xsd"> > > > > > > > > > > > > > > > > > > > > > > > > > name="nc2" > duplex="true" > networkTTL="6" > dynamicOnly="true" > prefetchSize="1" > conduitSubscriptions="true" > suppressDuplicateQueueSubscriptions="true" > suppressDuplicateTopicSubscriptions="true" > decreaseNetworkConsumerPriority="true" /> > > > > > > > > > > > > > > > > > > > > > > > > > > > > >--------------------------------------------------------------------------------------------------------------------------------------------------------- > > > > >At 2011-12-07 00:05:42,"Torsten Mielke" wrote: >>Yep, the latest release version. >>I have already seen a customer using it. >> >> >> >>On Dec 6, 2011, at 5:02 PM, SuoNayi wrote: >> >>> Thanks Torsten,It's the release version not snapshot version,right? >>> >>> http://repo.fusesource.com/nexus/content/repositories/releases/org/apache/activemq/apache-activemq/5.5.1-fuse-01-06/ >>> >>> >>> >>> >>> At 2011-12-06 23:44:49,"Torsten Mielke" wrote: >>>> The latest 5.5 release from FuseSource should already have this feature implemented, AFAIK. >>>> >>>> >>>> On Dec 6, 2011, at 3:43 PM, SuoNayi wrote: >>>> >>>>> Yes, it's a feature of AMQ 5.6 which is not released yet. >>>>> The trunk is a snapshot version but I want a release version for my product enviroment. >>>>> So I want to modify some to solve this issue. >>>>> >>>>> >>>>> >>>>> >>>>> At 2011-12-06 19:44:36,"Torsten Mielke" wrote: >>>>>> Hi, >>>>>> >>>>>> Is it the replayWhenNoConsumers feature that you're looking for? >>>>>> >>>>>> >>>>>> >>>>>> See http://activemq.apache.org/networks-of-brokers.html, part "Stuck messages". >>>>>> >>>>>> >>>>>> Torsten Mielke >>>>>> torsten@fusesource.com >>>>>> tmielke@blogspot.com >>>>>> >>>>>> >>>>>> >>>>>> On Dec 6, 2011, at 6:54 AM, SuoNayi wrote: >>>>>> >>>>>>> Hi all and professionals at fusesource, is there a simple way to solve the issuse of stuck messages when network? >>>>>>> Could I modify some source code ,for example the matchesForwardingFilter method in the class NetworkBridgeFilter ? >>>>>>> I want to annotate the line code which checks a message passes through the target broker or not, >>>>>>> but this maybe cause other potential and unknown problem. >>>>>>> So could anyone give me a advice or some tips?Thanks a lot! >>>>>> >>>>>> >>>>>> >>>> >>>> Torsten Mielke >>>> torsten@fusesource.com >>>> tmielke@blogspot.com >> > > > > >-- > >Wangyin >SuoNayi2006@163.com > ------=_Part_136763_871377236.1323248629640--