You previously said that you were statically configuring the network connectors, but in your last email you talked about advisory topics, which are only used for dynamically included destinations. Which approach are you using?
More generally, please post your broker configuration, since that may explain the behavior you're observing. Also, are you saying that the network behavior you see is different before a broker failover than after one? If so, which broker was the one that failed over? And to which broker was the consumer connected in each case you described? Your description of the missing logs in A sound like the consumer is connected to B, but your paragraph at the end sounded like the opposite. So a detailed description of how you're interacting with the network of brokers would help clarify what you're describing. Tim On Fri, Sep 14, 2018, 11:23 AM ievanliu <ievan...@qq.com> wrote: > Hi,Tim > > this problem happened very often recently. > > as run in this architecture： Broke A(a 3 instances jdbc cluster) and Broke > B(a 3 instances > jdbc cluster), use duplex network connect, from brokeB to brokeA > > once Broker B cluster happened fail-over event(master changed from B1 to > B2),then the bridge problem happened. > > I test that subscribe a queue test_queue to broke B,but in broke A ,there > even has no queue named test_queue,and there has no advisory topic in broke > A either > > normally,when subscribe a queue,the log is as below: > [log in brokerA] > [DEBUG][2018-09-14 16:33:46] localhost adding consumer: > localhost->bj_172.20.32.111-44717-1536908810883-4:1:1:13 for destination: > > queue://amq_admin_test45<--[org.apache.activemq.broker.region.AbstractRegion:338 > addConsumer] > [DEBUG][2018-09-14 16:33:46] localhost adding destination: > > queue://amq_admin_test45<--[org.apache.activemq.broker.region.AbstractRegion:154 > addDestination] > [DEBUG][2018-09-14 16:33:46] queue://amq_admin_test45, subscriptions=0, > memory=0%, size=0, pending=0 toPageIn: 0, force:false, Inflight: 0, > pagedInMessages.size 0, pagedInPendingDispatch.size 0, enqueueCount: 0, > dequeueCount: 0, memUsage:0, > maxPageSize:200<--[org.apache.activemq.broker.region.Queue:1913 > doPageInForDispatch] > [DEBUG][2018-09-14 16:33:46] queue://amq_admin_test45 add sub: > QueueSubscription: > consumer=localhost->bj_172.20.32.111-44717-1536908810883-4:1:1:13, > destinations=0, dispatched=0, delivered=0, pending=0, dequeues: 0, > dispatched: 0, inflight: 0<--[org.apache.activemq.broker.region.Queue:422 > addSubscription] > [DEBUG][2018-09-14 16:33:46] queue://amq_admin_test45, subscriptions=1, > memory=0%, size=0, pending=0 toPageIn: 0, force:false, Inflight: 0, > pagedInMessages.size 0, pagedInPendingDispatch.size 0, enqueueCount: 0, > dequeueCount: 0, memUsage:0, > maxPageSize:200<--[org.apache.activemq.broker.region.Queue:1913 > doPageInForDispatch] > [DEBUG][2018-09-14 16:33:46] localhost adding destination: > > topic://ActiveMQ.Advisory.Consumer.Queue.amq_admin_test45<--[org.apache.activemq.broker.region.AbstractRegion:154 > addDestination] > > > [log in BrokerB] > [DEBUG][2018-09-14 16:33:46] bj_172.20.32.111 adding consumer: > ID:cloudlab042-46597-1536908807725-7:22:-1:1 for destination: > > queue://amq_admin_test45<--[org.apache.activemq.broker.region.AbstractRegion:338 > addConsumer] > [DEBUG][2018-09-14 16:33:46] bj_172.20.32.111 adding destination: > > queue://amq_admin_test45<--[org.apache.activemq.broker.region.AbstractRegion:154 > addDestination] > [DEBUG][2018-09-14 16:33:46] queue://amq_admin_test45, subscriptions=0, > memory=0%, size=0, pending=0 toPageIn: 0, force:false, Inflight: 0, > pagedInMessages.size 0, pagedInPendingDispatch.size 0, enqueueCount: 0, > dequeueCount: 0, memUsage:0, > maxPageSize:200<--[org.apache.activemq.broker.region.Queue:1913 > doPageInForDispatch] > [DEBUG][2018-09-14 16:33:46] queue://amq_admin_test45 add sub: > QueueSubscription: consumer=ID:cloudlab042-46597-1536908807725-7:22:-1:1, > destinations=0, dispatched=0, delivered=0, pending=0, dequeues: 0, > dispatched: 0, inflight: 0<--[org.apache.activemq.broker.region.Queue:422 > addSubscription] > [DEBUG][2018-09-14 16:33:46] queue://amq_admin_test45, subscriptions=1, > memory=0%, size=0, pending=0 toPageIn: 0, force:false, Inflight: 0, > pagedInMessages.size 0, pagedInPendingDispatch.size 0, enqueueCount: 0, > dequeueCount: 0, memUsage:0, > maxPageSize:200<--[org.apache.activemq.broker.region.Queue:1913 > doPageInForDispatch] > [DEBUG][2018-09-14 16:33:46] bj_172.20.32.111 adding destination: > > topic://ActiveMQ.Advisory.Consumer.Queue.amq_admin_test45<--[org.apache.activemq.broker.region.AbstractRegion:154 > addDestination] > [DEBUG][2018-09-14 16:33:46] bridging (bj_172.20.32.111 -> localhost), > consumer: bj_172.20.32.111->localhost-46597-1536908807725-6:1:1:1, > destination: topic://ActiveMQ.Advisory.Consumer.Queue.amq_admin_test45, > brokerPath: [ID:cloudlab042-46597-1536908807725-0:1], message: > > ID:cloudlab042-46597-1536908807725-1:1:0:0:87<--[org.apache.activemq.network.DemandForwardingBridgeSupport:1070 > serviceLocalCommand] > > > but when problem happened,and then I subscribe anther queue in brokeB, I > found,there has no log of this queue bin BrokeA at all. > in BrokerB,log is as below:[DEBUG][2018-09-14 22:31:53] bj_172.20.32.109 > adding consumer: ID:bfjd-psc-bcop-vm16-60932-1536934894156-5:2:-1:1 for > destination: > > queue://amq_admin_test_nj<--[org.apache.activemq.broker.region.AbstractRegion:338 > addConsumer] > [DEBUG][2018-09-14 22:31:53] bj_172.20.32.109 adding destination: > > queue://amq_admin_test_nj<--[org.apache.activemq.broker.region.AbstractRegion:154 > addDestination] > [DEBUG][2018-09-14 22:31:53] queue://amq_admin_test_nj, subscriptions=0, > memory=0%, size=0, pending=0 toPageIn: 0, force:false, Inflight: 0, > pagedInMessages.size 0, pagedInPendingDispatch.size 0, enqueueCount: 0, > dequeueCount: 0, memUsage:0, > maxPageSize:200<--[org.apache.activemq.broker.region.Queue:1913 > doPageInForDispatch] > [DEBUG][2018-09-14 22:31:53] queue://amq_admin_test_nj add sub: > QueueSubscription: > consumer=ID:bfjd-psc-bcop-vm16-60932-1536934894156-5:2:-1:1, > destinations=0, > dispatched=0, delivered=0, pending=0, dequeues: 0, dispatched: 0, inflight: > 0<--[org.apache.activemq.broker.region.Queue:422 addSubscription] > [DEBUG][2018-09-14 22:31:53] queue://amq_admin_test_nj, subscriptions=1, > memory=0%, size=0, pending=0 toPageIn: 0, force:false, Inflight: 0, > pagedInMessages.size 0, pagedInPendingDispatch.size 0, enqueueCount: 0, > dequeueCount: 0, memUsage:0, > maxPageSize:200<--[org.apache.activemq.broker.region.Queue:1913 > doPageInForDispatch] > [DEBUG][2018-09-14 22:31:53] bj_172.20.32.109 adding destination: > > topic://ActiveMQ.Advisory.Consumer.Queue.amq_admin_test_nj<--[org.apache.activemq.broker.region.AbstractRegion:154 > addDestination] > [DEBUG][2018-09-14 22:32:23] queue://amq_admin_test_nj expiring messages > ..<--[org.apache.activemq.broker.region.Queue:904 expireMessages] > [DEBUG][2018-09-14 22:32:23] queue://amq_admin_test_nj expiring messages > done.<--[org.apache.activemq.broker.region.Queue:910 expireMessages] > > > I can see that this log did not happed: > "bridging (bj_172.20.32.111 -> localhost), consumer: > bj_172.20.32.111->localhost-46597-1536908807725-6:1:1:1, destination: > topic://ActiveMQ.Advisory.Consumer.Queue.amq_admin_test45, brokerPath: > [ID:cloudlab042-46597-1536908807725-0:1], message" > > > but there are some queues successfully built network connector from BrokeA > to BrokeB(the queue in BrokeB has a bridge connect as a consumer) > > this really puzzle me. > > > > -- > Sent from: > http://activemq.2283324.n4.nabble.com/ActiveMQ-User-f2341805.html >
