From users-return-50404-archive-asf-public=cust-asf.ponee.io@activemq.apache.org Tue Aug 28 07:33:25 2018 Return-Path: X-Original-To: archive-asf-public@cust-asf.ponee.io Delivered-To: archive-asf-public@cust-asf.ponee.io Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by mx-eu-01.ponee.io (Postfix) with SMTP id 15A53180674 for ; Tue, 28 Aug 2018 07:33:24 +0200 (CEST) Received: (qmail 42745 invoked by uid 500); 28 Aug 2018 05:33:19 -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 42722 invoked by uid 99); 28 Aug 2018 05:33:18 -0000 Received: from pnap-us-west-generic-nat.apache.org (HELO spamd3-us-west.apache.org) (209.188.14.142) by apache.org (qpsmtpd/0.29) with ESMTP; Tue, 28 Aug 2018 05:33:18 +0000 Received: from localhost (localhost [127.0.0.1]) by spamd3-us-west.apache.org (ASF Mail Server at spamd3-us-west.apache.org) with ESMTP id ACFEA1800C5 for ; Tue, 28 Aug 2018 05:33:17 +0000 (UTC) X-Virus-Scanned: Debian amavisd-new at spamd3-us-west.apache.org X-Spam-Flag: NO X-Spam-Score: 5.565 X-Spam-Level: ***** X-Spam-Status: No, score=5.565 tagged_above=-999 required=6.31 tests=[FREEMAIL_ENVFROM_END_DIGIT=0.25, HEADER_FROM_DIFFERENT_DOMAINS=0.001, HTML_MESSAGE=2, KAM_BADIPHTTP=2, RCVD_IN_DNSWL_NONE=-0.0001, SPF_PASS=-0.001, URI_HEX=1.313, URI_TRY_3LD=0.001, WEIRD_PORT=0.001] autolearn=disabled Received: from mx1-lw-eu.apache.org ([10.40.0.8]) by localhost (spamd3-us-west.apache.org [10.40.0.10]) (amavisd-new, port 10024) with ESMTP id H06AdgIFy4Ps for ; Tue, 28 Aug 2018 05:33:16 +0000 (UTC) Received: from mail-lj1-f180.google.com (mail-lj1-f180.google.com [209.85.208.180]) by mx1-lw-eu.apache.org (ASF Mail Server at mx1-lw-eu.apache.org) with ESMTPS id 694895F1EE for ; Tue, 28 Aug 2018 05:33:15 +0000 (UTC) Received: by mail-lj1-f180.google.com with SMTP id m84-v6so297884lje.10 for ; Mon, 27 Aug 2018 22:33:15 -0700 (PDT) X-Google-DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=1e100.net; s=20161025; h=x-gm-message-state:mime-version:references:in-reply-to:from:date :message-id:subject:to; bh=Gg4+mnytdeZfQtQXu6p38UvvClr2FR0cj4oxFUbEu8I=; b=FtE1eGjnrh5+RRdrO14d/KYStprrl1rMUE/PjOaIixfHnBynhJsqQjehXEFiPG0jIg GCXXMCd2wc+U4JwRZXTk9lbeNPz1rREET6/cwnR3yg15tYxqx5UANOjHWlZpj2i1n6PQ CFIn1kbAK2KaTa5wk7vHopQCTgmAM40g3ERS7LP3SKdTo/TFzTwC7HpsA/W2mY5WWjt9 LRECATNiZto1hoqvdUvpNs6tP9csA0FUQOYFgjCX8WDUIveSSt8+r6pclDtI6G62qvX8 f/rij1qeJOuEeS30LYpgk0JoXNmasOj5OMTfOCogS12am1pck8LwijC/Pf8iHDFwrX3C uEUw== X-Gm-Message-State: APzg51Bw6L9vVpR9MtH4pZdlMhBbKaPDBllbi0OyUgfCOOOWAMXui6U9 4TwhHwrK44dN1XasdVZkKJ7APgz2KUqoXhrKcnmS+pLU X-Google-Smtp-Source: ANB0VdZei+0ytB8seAuG2GcDPDqF99MndlJEoogfHf8Grhin8KUHmPiXmCW78S/B9lfKU5QIjMefezDDS2R9YkfB4Aw= X-Received: by 2002:a2e:58b:: with SMTP id 133-v6mr26462ljf.28.1535434394541; Mon, 27 Aug 2018 22:33:14 -0700 (PDT) MIME-Version: 1.0 References: <1535353691851-0.post@n4.nabble.com> In-Reply-To: <1535353691851-0.post@n4.nabble.com> From: Tim Bain Date: Mon, 27 Aug 2018 23:33:03 -0600 Message-ID: Subject: Re: cannot consume msg by a duplex network connect broke. To: ActiveMQ Users Content-Type: multipart/alternative; boundary="000000000000a9a2f30574782d0a" --000000000000a9a2f30574782d0a Content-Type: text/plain; charset="UTF-8" Content-Transfer-Encoding: quoted-printable As you said in #2, without a network bridge consumer, there will be no message flow through the network of brokers. So the question then is why network consumers aren't being created, given that in #1 you said that the logs indicate that the network bridge was successfully built. I notice that the snippet of activemq.xml that you quoted doesn't include any indication that you're including destinations either dynamically or statically (see Dynamic Networks and Pure Static Networks in http://activemq.apache.org/networks-of-brokers.html). Is that an accurate and complete quote from the file, or did you omit some of the content to focus our attention on the pieces you did include? What you quoted would be expected to result in no message flow between A and B, which matches your description of the problematic behavior wouldn't explain why this would have ever worked for you. If that doesn't lead us to an answer and you're able to reproduce the problem, I'd start by attempting to see if a socket connection between the brokers exists, and then using JMX to see whether a network consumer is built for the topic in question. If there's a network connection but no network consumer, then I'd want to attach a debugger and step through the code where the subscriptions are propagated. https://activemq.apache.org/maven/apidocs/org/apache/activemq/network/Deman= dForwardingBridgeSupport.html#isPermissableDestination-org.apache.activemq.= command.ActiveMQDestination-boolean- should be the right place to set your breakpoint, should you need to go down this path. Tim On Mon, Aug 27, 2018 at 7:26 AM ievanliu wrote: > version:5.14.0 > architecture=EF=BC=9A Broke A(a 3 instances jdbc cluster) and Broke B(a 3= instances > jdbc cluster), use duplex network connect, from brokeB to brokeA > productor produce messages into brokeA, consumers consume messages from > broke B, bridge queue like queueA,queueB > > > networkConnector config: > > > uri=3D"masterslave:(tcp://172.16.202.62:61616,tcp://172.16.202.65:61616 > ,tcp://172.16.202.68:61616)" > duplex=3D"true" name=3D"bridge_111"> > > > problem: > early this morning, brokeB happened a master change, by the pre-master lo= st > the jdbc lock. > broke B2 in the broke B cluster, successfuly became the master, and build > the network connection to broke A. > But, there is a problem that , producer can produce messages to BrokeA, b= ut > consumers cannot consumer message from brokeB. > > process: > 1=E3=80=81as the log shows, the network bridge has successfully been buil= t=E3=80=82and > there > are no other error logs info. > 2=E3=80=81I found that, when consumer connect to brokeB to consume queueA= , in broke > A, there is no consumers.Normally, here should be a network bridge consum= er > to brokeA.maybe this is the reason. > 3=E3=80=81restart the broke A and broke B=EF=BC=8Cthe problem happened as= same > > > result: > about 1 hours later, the problem disappear automaticly, and I can see the= re > is a network bridge consumer to brokeA. > > > who can help me how to troubleshooting this problem? > > > > -- > Sent from: > http://activemq.2283324.n4.nabble.com/ActiveMQ-User-f2341805.html > --000000000000a9a2f30574782d0a--