diff --git a/channels/joinedChannel.go b/channels/joinedChannel.go index ab24aaa8bf98441b4af0bf2a6560251d4313d126..2137740120da242b2d9bfcd1fff360dd63fda34a 100644 --- a/channels/joinedChannel.go +++ b/channels/joinedChannel.go @@ -49,7 +49,7 @@ func (m *manager) storeUnsafe() error { Data: data, } - return m.kv.Set(joinedChannelsKey, joinedChannelsVersion, obj) + return m.kv.Set(joinedChannelsKey, obj) } // loadChannels loads all currently joined channels from disk and registers them @@ -203,8 +203,7 @@ func (jc *joinedChannel) Store(kv *versioned.KV) error { Data: data, } - return kv.Set(makeJoinedChannelKey(jc.broadcast.Get().ReceptionID), - joinedChannelVersion, obj) + return kv.Set(makeJoinedChannelKey(jc.broadcast.Get().ReceptionID), obj) } // loadJoinedChannel loads a given channel from ekv storage.