We have a weird issue.
There are two equivalent topics: topicA
and topicB
.
The topics are created dynamically. Consumers subscribe to VirtualTopic.topicA
and VirtualTopic.topicB
correspondingly.
Consumers get the messages. We see equal number of arrived and dequeued messages in each virtual topic.
However, topicA
says it has active subscribers, whereas topicB
does not. All messages in topicA
are dequeued. topicB
shows the same number of messages as VirtualTopic.topicB
contains, but none of the message is dequeued in topicB
.
It looks like ActiveMQ just silently copies messages from regular to virtual topic. But it is not clear why it does it only for one of the topics.
Code which subscribes consumers is the same. Code that produces messages is the same. Configuration differs only in name of topics.
Can anyone give a hint what can define that difference in behaviour?
See Question&Answers more detail:
os 与恶龙缠斗过久,自身亦成为恶龙;凝视深渊过久,深渊将回以凝视…