git.net

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

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


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