[ https://issues.apache.org/activemq/browse/AMQ-776?page=comments#action_37135 ] Kevin Yaussy commented on AMQ-776: ----------------------------------
Hiram, With help from Holger Bruch on AMQ-961, this issue I think can be resolved. For AMQ 4.0.2, apply the ConduitBridge patch, which fixes the first part of this issue. Apply Holger's patch from AMQ-961 to DemandForwardingBridgeSupport. That fixes the issue from AMQ-961, but also the second part of this issue. > ConduitBridge can malfunction when first of a set of consumers goes away > ------------------------------------------------------------------------ > > Key: AMQ-776 > URL: https://issues.apache.org/activemq/browse/AMQ-776 > Project: ActiveMQ > Issue Type: Bug > Components: Broker > Affects Versions: 4.0.1 > Reporter: Kevin Yaussy > Assigned To: Rob Davies > Priority: Critical > Fix For: 4.0.3 > > Attachments: ConduitBridge.patch, DemandForwardingBridgeSupport.patch > > > When the following scenario is followed, any of the subsequent consumers will > stop receiving messages. I've reproduced this using the ConsumerTool, and > ProducerTool supplied in the example area of the distribution. > +++++++++++++++++++++++ > Start Broker A > Start Broker B > Start Consumer 1, connecting to Broker B, consuming FOO > Start Consumer 2, connecting to Broker B, consuming FOO > Start Publisher, connecting to Broker A, publishing FOO > Ctl-C out of Consumer 1 > Consumer 2 stops receiving messages > +++++++++++++++++++ > Seems to me that ConduitBridge is supposed to track all consumers for a given > subscription, by way of DemandSubscription. It is seeding DemandSubscription > with the originating consumer, but when subsequent consumers are added, the > ConduitBridge::addToAlreadyInterestedConsumers re-adds the original > subscriber to the DemandSubscription's map - so the map only ever has the > original subscription. > I've attached a patch. Hope the change is good. -- This message is automatically generated by JIRA. - If you think it was sent incorrectly contact one of the administrators: https://issues.apache.org/activemq/secure/Administrators.jspa - For more information on JIRA, see: http://www.atlassian.com/software/jira
