Shared subscriptions (JMS 2.0)
Le contrôle de flux de Topic (activate/passivate) ne semble pas fonctionner avec les souscriptions partagées.
Le traitement de ActivateConsumerRequest ne prend pas en compte les souscriptions partagées.
Je propose d'ajouter le code suivant :
if (req.getActivate() == 0) {
if (!sharedSubs.containsKey(subName)) {
sub.setActive(req.getActivate());
} else {
SharedCtx sharedCtx = sharedSubs.get(subName);
sharedCtx.remove(activeCtx.getId());
}
} else {
if (!sharedSubs.containsKey(subName)) {
sub.setActive(req.getActivate());
} } else {
SharedCtx sharedCtx = sharedSubs.get(subName);
sharedCtx.put(activeCtx.getId(), activeCtx.getId());
}
}
On pourrait faire mieux en ajoutant les 'getActivate' de chaque abonné.
[JORAM-213] created at 2015-01-23 18:02:14 by feliot, version JORAM_5_10_0