From 025f9b520503cf1423640ac115d5d16b49e29368 Mon Sep 17 00:00:00 2001 From: OpenIM-Gordon <46924906+FGadvancer@users.noreply.github.com> Date: Mon, 5 Feb 2024 10:29:19 +0800 Subject: [PATCH] Update init.go --- internal/msgtransfer/init.go | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/internal/msgtransfer/init.go b/internal/msgtransfer/init.go index 67b9afd98..65a6b1935 100644 --- a/internal/msgtransfer/init.go +++ b/internal/msgtransfer/init.go @@ -23,6 +23,7 @@ import ( "syscall" "time" "net/http" + "sync" "github.com/OpenIMSDK/tools/errs" @@ -119,7 +120,7 @@ func (m *MsgTransfer) Start(prometheusPort int) error { go func() { defer wg.Done() - m.m.historyCH.historyConsumerGroup.RegisterHandleAndConsumer(ctx, m.historyCH) + m.historyCH.historyConsumerGroup.RegisterHandleAndConsumer(ctx, m.historyCH) }() wg.Add(1)