Producer posts to topic and consumer subscribes to virtual topic
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?
activemq
asked Nov 12 '18 at 15:27
Pavel VoroninPavel Voronin
7,32353985
add a comment |
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?
activemq
asked Nov 12 '18 at 15:27
Pavel VoroninPavel Voronin
7,32353985
Need to provide code and output on what is happening as your question is very unclear.
– Tim Bish
Nov 14 '18 at 14:35
Producer sends message to topicpolicy.events'. Consumer is subscribed to virtual destinationqueue://Consumer.PermissionsService.VirtualTopic.policy.events. (shareable virtual topic). Number of enqueued messages increases forpolicy.events` topic, number of dequeued messages stays zero. Consumer gets the messages, acknowledges them, number of enqueued and dequeued messages is equal for consumer queue.
– Pavel Voronin
Nov 14 '18 at 17:19
add a comment |
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?
activemq
asked Nov 12 '18 at 15:27
Pavel VoroninPavel Voronin
7,32353985
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?
activemq
activemq
asked Nov 12 '18 at 15:27
Pavel VoroninPavel Voronin
7,32353985
asked Nov 12 '18 at 15:27
Pavel VoroninPavel Voronin
7,32353985
asked Nov 12 '18 at 15:27
Pavel VoroninPavel Voronin
7,32353985
asked Nov 12 '18 at 15:27
Pavel VoroninPavel Voronin
7,32353985
asked Nov 12 '18 at 15:27
Pavel VoroninPavel Voronin
7,32353985
7,32353985
Need to provide code and output on what is happening as your question is very unclear.
– Tim Bish
Nov 14 '18 at 14:35
Producer sends message to topicpolicy.events'. Consumer is subscribed to virtual destinationqueue://Consumer.PermissionsService.VirtualTopic.policy.events. (shareable virtual topic). Number of enqueued messages increases forpolicy.events` topic, number of dequeued messages stays zero. Consumer gets the messages, acknowledges them, number of enqueued and dequeued messages is equal for consumer queue.
– Pavel Voronin
Nov 14 '18 at 17:19
add a comment |
Need to provide code and output on what is happening as your question is very unclear.
– Tim Bish
Nov 14 '18 at 14:35
Producer sends message to topicpolicy.events'. Consumer is subscribed to virtual destinationqueue://Consumer.PermissionsService.VirtualTopic.policy.events. (shareable virtual topic). Number of enqueued messages increases forpolicy.events` topic, number of dequeued messages stays zero. Consumer gets the messages, acknowledges them, number of enqueued and dequeued messages is equal for consumer queue.
– Pavel Voronin
Nov 14 '18 at 17:19
Need to provide code and output on what is happening as your question is very unclear.
– Tim Bish
Nov 14 '18 at 14:35
Need to provide code and output on what is happening as your question is very unclear.
– Tim Bish
Nov 14 '18 at 14:35
Producer sends message to topic
policy.events'. Consumer is subscribed to virtual destination queue://Consumer.PermissionsService.VirtualTopic.policy.events. (shareable virtual topic). Number of enqueued messages increases for policy.events` topic, number of dequeued messages stays zero. Consumer gets the messages, acknowledges them, number of enqueued and dequeued messages is equal for consumer queue.– Pavel Voronin
Nov 14 '18 at 17:19
Producer sends message to topic
policy.events'. Consumer is subscribed to virtual destination queue://Consumer.PermissionsService.VirtualTopic.policy.events. (shareable virtual topic). Number of enqueued messages increases for policy.events` topic, number of dequeued messages stays zero. Consumer gets the messages, acknowledges them, number of enqueued and dequeued messages is equal for consumer queue.– Pavel Voronin
Nov 14 '18 at 17:19
add a comment |
0
active
oldest
votes
Your Answer
StackExchange.ifUsing("editor", function () {
StackExchange.using("externalEditor", function () {
StackExchange.using("snippets", function () {
StackExchange.snippets.init();
});
});
}, "code-snippets");
StackExchange.ready(function() {
var channelOptions = {
tags: "".split(" "),
id: "1"
};
initTagRenderer("".split(" "), "".split(" "), channelOptions);
StackExchange.using("externalEditor", function() {
// Have to fire editor after snippets, if snippets enabled
if (StackExchange.settings.snippets.snippetsEnabled) {
StackExchange.using("snippets", function() {
createEditor();
});
}
else {
createEditor();
}
});
function createEditor() {
StackExchange.prepareEditor({
heartbeatType: 'answer',
autoActivateHeartbeat: false,
convertImagesToLinks: true,
noModals: true,
showLowRepImageUploadWarning: true,
reputationToPostImages: 10,
bindNavPrevention: true,
postfix: "",
imageUploader: {
brandingHtml: "Powered by u003ca class="icon-imgur-white" href="https://imgur.com/"u003eu003c/au003e",
contentPolicyHtml: "User contributions licensed under u003ca href="https://creativecommons.org/licenses/by-sa/3.0/"u003ecc by-sa 3.0 with attribution requiredu003c/au003e u003ca href="https://stackoverflow.com/legal/content-policy"u003e(content policy)u003c/au003e",
allowUrls: true
},
onDemand: true,
discardSelector: ".discard-answer"
,immediatelyShowMarkdownHelp:true
});
}
});
Sign up or log in
StackExchange.ready(function () {
StackExchange.helpers.onClickDraftSave('#login-link');
});
Sign up using Google
Sign up using Facebook
Sign up using Email and Password
Post as a guest
Required, but never shown
StackExchange.ready(
function () {
StackExchange.openid.initPostLogin('.new-post-login', 'https%3a%2f%2fstackoverflow.com%2fquestions%2f53265279%2fproducer-posts-to-topic-and-consumer-subscribes-to-virtual-topic%23new-answer', 'question_page');
}
);
Post as a guest
Required, but never shown
0
active
oldest
votes
0
active
oldest
votes
active
oldest
votes
active
oldest
votes
Thanks for contributing an answer to Stack Overflow!
- Please be sure to answer the question. Provide details and share your research!
But avoid …
- Asking for help, clarification, or responding to other answers.
- Making statements based on opinion; back them up with references or personal experience.
To learn more, see our tips on writing great answers.
Sign up or log in
StackExchange.ready(function () {
StackExchange.helpers.onClickDraftSave('#login-link');
});
Sign up using Google
Sign up using Facebook
Sign up using Email and Password
Post as a guest
Required, but never shown
StackExchange.ready(
function () {
StackExchange.openid.initPostLogin('.new-post-login', 'https%3a%2f%2fstackoverflow.com%2fquestions%2f53265279%2fproducer-posts-to-topic-and-consumer-subscribes-to-virtual-topic%23new-answer', 'question_page');
}
);
Post as a guest
Required, but never shown
Sign up or log in
StackExchange.ready(function () {
StackExchange.helpers.onClickDraftSave('#login-link');
});
Sign up using Google
Sign up using Facebook
Sign up using Email and Password
Post as a guest
Required, but never shown
Sign up or log in
StackExchange.ready(function () {
StackExchange.helpers.onClickDraftSave('#login-link');
});
Sign up using Google
Sign up using Facebook
Sign up using Email and Password
Post as a guest
Required, but never shown
Sign up or log in
StackExchange.ready(function () {
StackExchange.helpers.onClickDraftSave('#login-link');
});
Sign up using Google
Sign up using Facebook
Sign up using Email and Password
Sign up using Google
Sign up using Facebook
Sign up using Email and Password
Post as a guest
Required, but never shown
Required, but never shown
Required, but never shown
Required, but never shown
Required, but never shown
Required, but never shown
Required, but never shown
Required, but never shown
Required, but never shown
Need to provide code and output on what is happening as your question is very unclear.
– Tim Bish
Nov 14 '18 at 14:35
Producer sends message to topic
policy.events'. Consumer is subscribed to virtual destinationqueue://Consumer.PermissionsService.VirtualTopic.policy.events. (shareable virtual topic). Number of enqueued messages increases forpolicy.events` topic, number of dequeued messages stays zero. Consumer gets the messages, acknowledges them, number of enqueued and dequeued messages is equal for consumer queue.– Pavel Voronin
Nov 14 '18 at 17:19