Update init.go

2 years ago · 025f9b5205
parent 964fad777a
commit 025f9b5205
1 changed files with 2 additions and 1 deletions
--- 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)