git.net

[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]

Re: cannot consume msg by a duplex network connect broke.


If you're not explicitly including destinations to be propagated across the
bridge, this is expected behavior. Configure destinations to include (I
recommend dynamic inclusion) and give it another try.

Tim

On Wed, Aug 29, 2018, 1:33 AM ievanliu <ievanliu@xxxxxx> wrote:

> Hi,Tim.
> thank you very much for your help.
> here are some more information:
>
> 1.the network connect configuration is the same as what we use in this
> problem,so most values should be defaults value.
> 2.these days, I compared the log very carefully,and I found that, when the
> problem happens, broke did not create a bridge-consumer.
>
> but why that happened?
> please help me?
>
> ------------------------------------------------------
> test case:
> produce messages into broke A,and consume messages from broke B.broke B
> config duplex network connect to Broke A
> ------------------------------------------------------
> #####when the problem happen,the log is as below:
> [broke A]
> [DEBUG][2018-08-21 10:05:24] brokeA adding destination:
>
> queue://amq_admin_test<--[org.apache.activemq.broker.region.AbstractRegion:154
> addDestination]
> [DEBUG][2018-08-21 10:05:24] queue://amq_admin_test, 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-08-21 10:05:24] brokeA Message
> ID:NFJD-PSC-BCOP-COREVM25-59961-1534816937032-9:1:-1:1:1 sent to
> queue://amq_admin_test<--[org.apache.activemq.broker.region.Queue:1842
> messageSent]
> [DEBUG][2018-08-21 10:05:24] queue://amq_admin_test, subscriptions=0,
> memory=0%, size=1, pending=0 toPageIn: 1, force:false, Inflight: 0,
> pagedInMessages.size 0, pagedInPendingDispatch.size 0, enqueueCount: 1,
> dequeueCount: 0, memUsage:1065,
> maxPageSize:200<--[org.apache.activemq.broker.region.Queue:1913
> doPageInForDispatch]
> [DEBUG][2018-08-21 10:05:24] localhost Message
> ID:NFJD-PSC-BCOP-COREVM25-59961-1534816937032-9:1:-1:1:2 sent to
> queue://amq_admin_test<--[org.apache.activemq.broker.region.Queue:1842
> messageSent]
> [DEBUG][2018-08-21 10:05:24] queue://amq_admin_test, subscriptions=0,
> memory=0%, size=2, pending=0 toPageIn: 2, force:false, Inflight: 0,
> pagedInMessages.size 0, pagedInPendingDispatch.size 0, enqueueCount: 2,
> dequeueCount: 0, memUsage:2130,
> maxPageSize:200<--[org.apache.activemq.broker.region.Queue:1913
> doPageInForDispatch]
> [DEBUG][2018-08-21 10:05:24] localhost Message
> ID:NFJD-PSC-BCOP-COREVM25-59961-1534816937032-9:1:-1:1:3 sent to
> queue://amq_admin_test<--[org.apache.activemq.broker.region.Queue:1842
> messageSent]
> [DEBUG][2018-08-21 10:05:24] queue://amq_admin_test, subscriptions=0,
> memory=0%, size=3, pending=0 toPageIn: 3, force:false, Inflight: 0,
> pagedInMessages.size 0, pagedInPendingDispatch.size 0, enqueueCount: 3,
> dequeueCount: 0, memUsage:3195,
> maxPageSize:200<--[org.apache.activemq.broker.region.Queue:1913
> doPageInForDispatch]
>
>
>
> [broke B]
> [DEBUG][2018-08-21 10:07:22] brokeB adding consumer:
> ID:XXXXXX-vm18-47733-1534816696571-13:1:-1:1 for destination:
>
> queue://amq_admin_test<--[org.apache.activemq.broker.region.AbstractRegion:338
> addConsumer]
> [DEBUG][2018-08-21 10:07:22] brokeB adding destination:
>
> queue://amq_admin_test<--[org.apache.activemq.broker.region.AbstractRegion:154
> addDestination]
> [DEBUG][2018-08-21 10:07:22] queue://amq_admin_test, 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-08-21 10:07:22] queue://amq_admin_test add sub:
> QueueSubscription: consumer=ID:XXXXXX-vm18-47733-1534816696571-13:1:-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-08-21 10:07:22] queue://amq_admin_test, 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-08-21 10:07:22] brokeB adding destination:
>
> topic://ActiveMQ.Advisory.Consumer.Queue.amq_admin_test<--[org.apache.activemq.broker.region.AbstractRegion:154
> addDestination]
>
>
>
> ######normally, the log is as below
> [broke A]
> [DEBUG][2018-08-29 14:48:24] brokeA adding consumer:
> brokeA->brokeB-45659-1535359315047-21:1:1:8 for destination:
>
> queue://amq_admin_test<--[org.apache.activemq.broker.region.AbstractRegion:338
> addConsumer]
> [DEBUG][2018-08-29 14:48:24] queue://amq_admin_test add sub:
> QueueSubscription:
> consumer=localhost->bj_172.20.32.111-45659-1535359315047-21:1:1:8,
> destinations=0, dispatched=0, delivered=0, pending=0, dequeues: 0,
> dispatched: 0, inflight: 0<--[org.apache.activemq.broker.region.Queue:422
> addSubscription]
> [DEBUG][2018-08-29 14:48:24] queue://amq_admin_test, subscriptions=1,
> memory=0%, size=3, pending=0 toPageIn: 0, force:false, Inflight: 0,
> pagedInMessages.size 3, pagedInPendingDispatch.size 3, enqueueCount: 3,
> dequeueCount: 0, memUsage:3195,
> maxPageSize:200<--[org.apache.activemq.broker.region.Queue:1913
> doPageInForDispatch]
> [DEBUG][2018-08-29 14:48:24] Publishing: vm://localhost for broker
> transport
> URI: vm://localhost<--[org.apache.activemq.broker.TransportConnector:268
> getPublishableConnectString]
> [DEBUG][2018-08-29 14:48:24] bridging (brokeA -> brokeB), consumer:
> localhost->bj_172.20.32.111-45659-1535359315047-21:1:1:8, destination:
> queue://amq_admin_test, brokerPath:
> [ID:cloudlab043-45659-1535359315047-0:1], message:
>
> ID:cloudlab043-45659-1535359315047-13:3:-1:1:1<--[org.apache.activemq.network.DemandForwardingBridgeSupport:1070
> serviceLocalCommand]
> [DEBUG][2018-08-29 14:48:24] localhost new demand subscription:
>
> DemandSub{brokeA->brokeB-45659-1535359315047-21:1:1:8,remotes:[ID:XXXXXXXXX-54561-1535506233797-5:12:-1:1]}<--[org.apache.activemq.network.DemandForwardingBridgeSupport:1305
> addConsumerInfo]
>
> [broke B]
> [DEBUG][2018-08-29 14:48:25] brokeB adding consumer:
> ID:cloudlab042-54561-1535506233797-5:12:-1:1 for destination:
>
> queue://amq_admin_test<--[org.apache.activemq.broker.region.AbstractRegion:338
> addConsumer]
> [DEBUG][2018-08-29 14:48:25] brokeB adding destination:
>
> queue://amq_admin_test<--[org.apache.activemq.broker.region.AbstractRegion:154
> addDestination]
> [DEBUG][2018-08-29 14:48:25] queue://amq_admin_test, 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-08-29 14:48:25] queue://amq_admin_test add sub:
> QueueSubscription: consumer=ID:XXXXXXXX-54561-1535506233797-5:12:-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-08-29 14:48:25] brokeB adding destination:
>
> topic://ActiveMQ.Advisory.Consumer.Queue.amq_admin_test<--[org.apache.activemq.broker.region.AbstractRegion:154
> addDestination]
> [DEBUG][2018-08-29 14:48:25] queue://amq_admin_test, 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-08-29 14:48:25] bridging (brokeB -> localhost), consumer:
> bj_172.20.32.111->brokeA-54561-1535506233797-4:1:1:1, destination:
> topic://ActiveMQ.Advisory.Consumer.Queue.amq_admin_test, brokerPath:
> [ID:cloudlab042-54561-1535506233797-0:1], message:
>
> ID:cloudlab042-54561-1535506233797-1:1:0:0:275<--[org.apache.activemq.network.DemandForwardingBridgeSupport:1070
> serviceLocalCommand]
> [DEBUG][2018-08-29 14:48:25] brokeB Message
> ID:cloudlab043-45659-1535359315047-13:3:-1:1:1 sent to
> queue://amq_admin_test<--[org.apache.activemq.broker.region.Queue:1842
> messageSent]
> [DEBUG][2018-08-29 14:48:25] queue://amq_admin_test, subscriptions=1,
> memory=0%, size=1, pending=0 toPageIn: 1, force:false, Inflight: 0,
> pagedInMessages.size 0, pagedInPendingDispatch.size 0, enqueueCount: 1,
> dequeueCount: 0, memUsage:1065,
> maxPageSize:200<--[org.apache.activemq.broker.region.Queue:1913
> doPageInForDispatch]
>
>
>
>
> --
> Sent from:
> http://activemq.2283324.n4.nabble.com/ActiveMQ-User-f2341805.html
>