Return-Path: X-Original-To: archive-asf-public-internal@cust-asf2.ponee.io Delivered-To: archive-asf-public-internal@cust-asf2.ponee.io Received: from cust-asf.ponee.io (cust-asf.ponee.io [163.172.22.183]) by cust-asf2.ponee.io (Postfix) with ESMTP id 202AC200CD2 for ; Thu, 27 Jul 2017 16:04:20 +0200 (CEST) Received: by cust-asf.ponee.io (Postfix) id 1CB5C169EE5; Thu, 27 Jul 2017 14:04:20 +0000 (UTC) Delivered-To: archive-asf-public@cust-asf.ponee.io Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by cust-asf.ponee.io (Postfix) with SMTP id 62A09169ED7 for ; Thu, 27 Jul 2017 16:04:19 +0200 (CEST) Received: (qmail 57275 invoked by uid 500); 27 Jul 2017 14:04:13 -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 57262 invoked by uid 99); 27 Jul 2017 14:04:11 -0000 Received: from pnap-us-west-generic-nat.apache.org (HELO spamd2-us-west.apache.org) (209.188.14.142) by apache.org (qpsmtpd/0.29) with ESMTP; Thu, 27 Jul 2017 14:04:11 +0000 Received: from localhost (localhost [127.0.0.1]) by spamd2-us-west.apache.org (ASF Mail Server at spamd2-us-west.apache.org) with ESMTP id 4F1A71A0B38 for ; Thu, 27 Jul 2017 14:04:11 +0000 (UTC) X-Virus-Scanned: Debian amavisd-new at spamd2-us-west.apache.org X-Spam-Flag: NO X-Spam-Score: 2.733 X-Spam-Level: ** X-Spam-Status: No, score=2.733 tagged_above=-999 required=6.31 tests=[KAM_NUMSUBJECT=0.5, RCVD_IN_DNSWL_NONE=-0.0001, SPF_FAIL=0.919, URI_HEX=1.313, URI_TRY_3LD=0.001] autolearn=disabled Received: from mx1-lw-us.apache.org ([10.40.0.8]) by localhost (spamd2-us-west.apache.org [10.40.0.9]) (amavisd-new, port 10024) with ESMTP id IoKGrgZzsXhO for ; Thu, 27 Jul 2017 14:04:09 +0000 (UTC) Received: from mwork.nabble.com (mwork.nabble.com [162.253.133.43]) by mx1-lw-us.apache.org (ASF Mail Server at mx1-lw-us.apache.org) with ESMTP id C2DF95FBC0 for ; Thu, 27 Jul 2017 14:04:08 +0000 (UTC) Received: from mjoe.nabble.com (unknown [162.253.133.57]) by mwork.nabble.com (Postfix) with ESMTP id 8303756A17D28 for ; Thu, 27 Jul 2017 07:04:08 -0700 (MST) Date: Thu, 27 Jul 2017 07:04:07 -0700 (PDT) From: tpavelka To: users@activemq.apache.org Message-ID: <1501164247856-4728963.post@n4.nabble.com> In-Reply-To: <1501162637930-4728962.post@n4.nabble.com> References: <1500447481392-4728671.post@n4.nabble.com> <1500467132551-4728675.post@n4.nabble.com> <1500985180512-4728871.post@n4.nabble.com> <1501074790883-4728926.post@n4.nabble.com> <1501077850828-4728931.post@n4.nabble.com> <1501162637930-4728962.post@n4.nabble.com> Subject: Re: Duplicate messages received with ActiveMQ 5.13.2 MIME-Version: 1.0 Content-Type: text/plain; charset=us-ascii Content-Transfer-Encoding: 7bit archived-at: Thu, 27 Jul 2017 14:04:20 -0000 BTW here is where I am getting stuck: I was assuming that brokers must somehow learn about consumers on other brokers. I looked at the code of org.apache.activemq.network.ConduitBridge and later org.apache.activemq.network.DemandForwardingBridge and it seemed to me that the means by which the brokers learn about consumers is by sending and receiving instances of org.apache.activemq.command.ConsumerInfo. So I put a breakpoint in org.apache.activemq.transport.TransportSupport#doConsume and I log every instance of ConsumerInfo. But I am only seeing ConsumerInfo's for some advisory topics and not for the topic which I am sending messages to. So either I don't have the tracing setup right or there is some other channel via which brokers exchange information about consumers. -- View this message in context: http://activemq.2283324.n4.nabble.com/Duplicate-messages-received-with-ActiveMQ-5-13-2-tp4728627p4728963.html Sent from the ActiveMQ - User mailing list archive at Nabble.com.