1. When storing a queue/binding/exchange in DB 2. and when notifying the change is sent via Hazlecast
same encoded string is used. So now the recovery from DB is straightforward. On Sat, Sep 27, 2014 at 5:48 PM, Hasitha Hiranya <hasit...@wso2.com> wrote: > Removed following classes > > interface ClusterCoordinationManager > class ClusterwideSubscriptionChangeNotifier > SubscriptionNotification - now all queues/exchanges/bindings are synced by > a common notification type called "clusterSubscription" > > ClusterSubscription structure - > >> notification message description > >> notification body as a encoded string > >> notification type - add/delete etc > > On Sat, Sep 27, 2014 at 5:48 PM, Hasitha Hiranya <hasit...@wso2.com> > wrote: > >> Moved initalizing code of andes kernel to a new class >> >> AndesKernelBoot - now Andes kernel startup code lies here. Decoupled from >> Qpid >> >> >>loadConfigurations - done from outside >> >>startAndesStores - done from outside >> >>startAndesComponents() >> >>startHouseKeepingThreads() >> >>syncNodeWithClusterState() >> >>registerMBeans() >> >>startMessaging() >> >> On Sat, Sep 27, 2014 at 5:47 PM, Hasitha Hiranya <hasit...@wso2.com> >> wrote: >> >>> Introduced following new classes >>> >>> ClusterCoordinationHandler implements QueueListener, ExchangeListener, >>> BindingListener, SubscriptionListener >>> >>> >> one place to handle all cluster coordination >>> >>> AndesRecoveryTask - reload from DB time to time in case of cluster >>> notification miss and simulate cluster notifications - TODO: to update >>> default recovery task interval in config file >>> >>> AMQPConstructStore - keeps queues/bindings/exchanges - ultimately refers >>> AndesContextStore >>> >>> On Sat, Sep 27, 2014 at 5:46 PM, Hasitha Hiranya <hasit...@wso2.com> >>> wrote: >>> >>>> Hi, >>>> >>>> I began the $subject. >>>> Idea is to instead of deriving queues/bindings/exchanges from >>>> subscriptions sync them Independently. >>>> >>>> I introduced QueueListener/BindingListener/ExchangeListner in the same >>>> way as subscription listener >>>> >>>> Thanks >>>> >>>> -- >>>> *Hasitha Abeykoon* >>>> Senior Software Engineer; WSO2, Inc.; http://wso2.com >>>> *cell:* *+94 719363063* >>>> *blog: **abeykoon.blogspot.com* <http://abeykoon.blogspot.com> >>>> >>>> >>> >>> >>> -- >>> *Hasitha Abeykoon* >>> Senior Software Engineer; WSO2, Inc.; http://wso2.com >>> *cell:* *+94 719363063* >>> *blog: **abeykoon.blogspot.com* <http://abeykoon.blogspot.com> >>> >>> >> >> >> -- >> *Hasitha Abeykoon* >> Senior Software Engineer; WSO2, Inc.; http://wso2.com >> *cell:* *+94 719363063* >> *blog: **abeykoon.blogspot.com* <http://abeykoon.blogspot.com> >> >> > > > -- > *Hasitha Abeykoon* > Senior Software Engineer; WSO2, Inc.; http://wso2.com > *cell:* *+94 719363063* > *blog: **abeykoon.blogspot.com* <http://abeykoon.blogspot.com> > > -- *Hasitha Abeykoon* Senior Software Engineer; WSO2, Inc.; http://wso2.com *cell:* *+94 719363063* *blog: **abeykoon.blogspot.com* <http://abeykoon.blogspot.com>
_______________________________________________ Dev mailing list Dev@wso2.org http://wso2.org/cgi-bin/mailman/listinfo/dev
