From fdf8352dc127e84e08ec5a2785834a33b0faba19 Mon Sep 17 00:00:00 2001 From: Richard Ramos Date: Thu, 25 Jul 2024 17:07:47 -0400 Subject: [PATCH] fix: topic --- cmd/storemsgcounter/execute.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/cmd/storemsgcounter/execute.go b/cmd/storemsgcounter/execute.go index 6babe30..eea8aea 100644 --- a/cmd/storemsgcounter/execute.go +++ b/cmd/storemsgcounter/execute.go @@ -341,7 +341,7 @@ func (app *Application) fetchStoreNodeMessages(ctx context.Context, runId string msgMap[hash] = make(map[peer.ID]MessageExistence) } msgMap[hash][storenodeID] = Exists - msgPubsubTopic[hash] = mkv.GetPubsubTopic() + msgPubsubTopic[hash] = topic } msgMapLock.Unlock()