From c74221e4da3a6a967039b6283dd1a209b0ac5472 Mon Sep 17 00:00:00 2001 From: sunby Date: Mon, 8 Feb 2021 16:42:56 +0800 Subject: [PATCH] Change ttMsgStream of dataservice to MsgStream Signed-off-by: sunby --- internal/dataservice/server.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/internal/dataservice/server.go b/internal/dataservice/server.go index 318b104de7..d6a3e60513 100644 --- a/internal/dataservice/server.go +++ b/internal/dataservice/server.go @@ -188,7 +188,7 @@ func (s *Server) initSegmentInfoChannel() { } func (s *Server) initMsgProducer() error { var err error - if s.ttMsgStream, err = s.msFactory.NewTtMsgStream(s.ctx); err != nil { + if s.ttMsgStream, err = s.msFactory.NewMsgStream(s.ctx); err != nil { return err } s.ttMsgStream.AsConsumer([]string{Params.TimeTickChannelName}, Params.DataServiceSubscriptionName)