diff --git a/wakuv2/waku.go b/wakuv2/waku.go index 149379805..f3b3c9f74 100644 --- a/wakuv2/waku.go +++ b/wakuv2/waku.go @@ -1376,7 +1376,7 @@ func (w *Waku) Start() error { //TODO: needs fixing, right now invoking everytime. //Trigger FilterManager to take care of any pending filter subscriptions //TODO: Pass pubsubTopic based on topicHealth notif received. - go w.filterManager.onConnectionStatusChange(w.cfg.DefaultShardPubsubTopic, isOnline) + go w.filterManager.onConnectionStatusChange("", isOnline) } w.connStatusMu.Lock()