Adding to architecture@.
On Mon, Jul 21, 2014 at 3:09 PM, Sajini De Silva <[email protected]> wrote: > Hi, > > I'm implementing the $subject in MB 3.0.0. Currently in an MB cluster if > there is only one subscriber for a particular queue GlobalQueueWorker(GQW) > copy all the messages which come to that particular queue, to node queue in > the subscriber's MB node. If another subscriber joins from another node > after GQW copied its all messages to another node queue there is no way the > new subscriber can get any messages even though most of the messages are > not delivered to the previous subscriber. > > The idea here is to introduce two threshold values known as > HighWaterMark(HWM) level and LowWaterMark(LWM) level in order to avoid the > above scenario. So that GQW copies messages to a node queue only up to HWM > even though there are many more messages. If another subscriber joins to > the cluster later he will not be starved. When a nodeQueue hits the LWM > threshold if there are more messages in the global queue, node queue will > be filled up to HWM by the GQW. > > I'll update the thread as I progress. > > Thank you, > Sajini. > > -- > Sajini De SIlva > Software Engineer; WSO2 Inc.; http://wso2.com , > Email: [email protected] > Blog: http://sajinid.blogspot.com/ > Git hub profile: https://github.com/sajinidesilva > > -- Sajini De SIlva Software Engineer; WSO2 Inc.; http://wso2.com , Email: [email protected] Blog: http://sajinid.blogspot.com/ Git hub profile: https://github.com/sajinidesilva
_______________________________________________ Architecture mailing list [email protected] https://mail.wso2.org/cgi-bin/mailman/listinfo/architecture
