diff --git a/docs/developer_guides/chap04_message_stream.md b/docs/developer_guides/chap04_message_stream.md index 83d258ad95..3b15440d96 100644 --- a/docs/developer_guides/chap04_message_stream.md +++ b/docs/developer_guides/chap04_message_stream.md @@ -324,12 +324,12 @@ func (ms *RmqMsgStream) SetRepackFunc(repackFunc RepackFunc) func NewRmqMsgStream(ctx context.Context) *RmqMsgStream type RmqTtMsgStream struct { - client *rockermq.RocksMQ + client *rockermq.RocksMQ repackFunc RepackFunc - producers []string - consumers []string - subName string - unmarshal *UnmarshalDispatcher + producers []string + consumers []string + subName string + unmarshal *UnmarshalDispatcher } func (ms *RmqTtMsgStream) Start() error