X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=syncstorage.go;h=349bcc3a58af9124d838fa66ba6371e3b32d5954;hb=d14c9d8bc5ed846c4b9f05af739eb9fba1978737;hp=4571dd9eb6435f7eee7e937d2ab45768990c27d8;hpb=1fb0e222e95d5af6df20d922501f585c1ef9fd0b;p=ric-plt%2Fsdlgo.git

diff --git a/syncstorage.go b/syncstorage.go
index 4571dd9..349bcc3 100644
--- a/syncstorage.go
+++ b/syncstorage.go
@@ -93,16 +93,14 @@ func getHash(s string) uint32 {
 //events received from different channels, callbacks are called in series one by one.
 func (s *SyncStorage) SubscribeChannel(ns string, cb func(string, ...string), channels ...string) error {
 	nsPrefix := getNsPrefix(ns)
-	s.getDbBackend(ns).SubscribeChannelDB(cb, s.setNamespaceToChannels(nsPrefix, channels...)...)
-	return nil
+	return s.getDbBackend(ns).SubscribeChannelDB(cb, s.setNamespaceToChannels(nsPrefix, channels...)...)
 }
 
 //UnsubscribeChannel removes subscription from one or several channels under given
 //namespace.
 func (s *SyncStorage) UnsubscribeChannel(ns string, channels ...string) error {
 	nsPrefix := getNsPrefix(ns)
-	s.getDbBackend(ns).UnsubscribeChannelDB(s.setNamespaceToChannels(nsPrefix, channels...)...)
-	return nil
+	return s.getDbBackend(ns).UnsubscribeChannelDB(s.setNamespaceToChannels(nsPrefix, channels...)...)
 }
 
 //Close connection to backend database.
@@ -639,8 +637,8 @@ func getNsPrefix(ns string) string {
 }
 
 type iDatabase interface {
-	SubscribeChannelDB(cb func(string, ...string), channels ...string)
-	UnsubscribeChannelDB(channels ...string)
+	SubscribeChannelDB(cb func(string, ...string), channels ...string) error
+	UnsubscribeChannelDB(channels ...string) error
 	MSet(pairs ...interface{}) error
 	MSetMPub(channelsAndEvents []string, pairs ...interface{}) error
 	MGet(keys []string) ([]interface{}, error)