You are viewing a plain text version of this content. The canonical link for it is here.
Posted to gitbox@activemq.apache.org by GitBox <gi...@apache.org> on 2021/05/24 11:22:14 UTC

[GitHub] [activemq] cshannon edited a comment on pull request #656: AMQ-8277 Copy consumerinfo (removing the additional predicate) before…

cshannon edited a comment on pull request #656:
URL: https://github.com/apache/activemq/pull/656#issuecomment-846975779


   The main issue I see here is what you pointed out...while this prevents the error it would result in not filtering between brokers and may cause unintended behavior which isn't great either and the only real way to fix it is to make the predicate be included by OpenWire (maybe another version or what you already tried)
   
   For the topic scenario (and using conduit subscriptions) it would work fine as selectors are not used anyways as it is pub/sub and messages are just broadcast so when the messages hit the different brokers they can be filtered there.
   
   When using a queue with multiple consumers I would think this would lead to stuck messages. For example a scenario might be if you had 3 brokers (A, B, C) and you create consumers on A and B with different predicates but those predicates are now filtered out when creating demand with advisories. That means if a message is published to broker C that could would match the predicate on consumer on A but not B it may still be forwarded to B and now stuck.
   
   I'm not really sure how much it matters as I doubt many people are doing this as this issue would have been brought up more often. This fix would probably be ok as long as we update the documentation on the network of brokers page and add something that specifically points out that if that field is set a network of brokers ignores it.


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

For queries about this service, please contact Infrastructure at:
users@infra.apache.org