Change-Id: I19439f8af09a5d6547275c39a8df2bbb2f4069b3
Signed-off-by: Mohamed Abukar <abukar.mohamed@nokia.com>
}
}
+func (r *RNIBClient) Subscribe(cb func(string, ...string), channel string) error {
+ return r.db.SubscribeChannel(cb, channel)
+}
+
+func (r *RNIBClient) StoreAndPublish(channel string, event string, pairs ...interface{}) error {
+ return r.db.SetAndPublish([]string{channel, event}, pairs...)
+}
+
func (r *RNIBClient) GetNodeb(invName string) (*RNIBNodebInfo, RNIBIRNibError) {
return rnibreader.GetRNibReader(r.db).GetNodeb(invName)
}