From acb36d081b9f046c0fd62f9ee6a97cf86bc3a3b2 Mon Sep 17 00:00:00 2001
From: Edward <chenlulei@gmail.com>
Date: Fri, 8 May 2020 20:33:06 +0800
Subject: [PATCH] add comments

---
 gomore/01_messages/message_test.go | 6 ++++--
 1 file changed, 4 insertions(+), 2 deletions(-)

diff --git a/gomore/01_messages/message_test.go b/gomore/01_messages/message_test.go
index fcec0f1..0c253cb 100644
--- a/gomore/01_messages/message_test.go
+++ b/gomore/01_messages/message_test.go
@@ -11,13 +11,14 @@ import (
 ////////////////////////////////
 //通常意义上是，连接消息队列之后就可以发送消息
 //当订阅著之后才会收到相关Topic消息的推送
+//当前，省略连接队列的步骤和操作代码
 ////////////////////////////////
 
 func TestMessageSubAndPubWithTopic(t *testing.T) {
 	var wg sync.WaitGroup
 
 	topicName := "seeking passengers"
-	//假设评估
+	//假设消息队列已经收到数据，加下来由topic处理
 	topic := Topic{
 		Name:          topicName,
 		UserQueueSize: 5,
@@ -26,8 +27,8 @@ func TestMessageSubAndPubWithTopic(t *testing.T) {
 	ctx, cancel := context.WithCancel(context.Background())
 
 	wg.Add(1)
-	//user 1
 
+	//user 1
 	//用户tom订阅拼车消息,订阅的是车主发布的拼车消息
 	if subScriberTom, ok := topic.Subscribe(123, topicName); ok {
 
@@ -52,6 +53,7 @@ func TestMessageSubAndPubWithTopic(t *testing.T) {
 	}
 
 	wg.Add(1)
+
 	//订阅成功了
 	//发送一个消息