test

odbc/client_test.go

@@ -39,7 +39,7 @@ func TestConcurrent(t *testing.T) {
 	}
 
 	log.Info("开启事件订阅")
-	odbc.SubscribeTest(client)
+	odbc.SubscribeDataChangeTest(client)
 
 	log.Info("开始创建相关类", classname)
 	cns := regexp.MustCompile("^/([^/]+)/([^/]+)").FindAllStringSubmatch(classname, -1)

odbc/subscribe.go

@@ -7,12 +7,12 @@ import (
 	"git.wecise.com/wecise/odb-go/odb/eventmsg"
 )
 
-func SubscribeTest(client odb.Client) {
-	Subscribe(client, "CLASS_DATA_CHANGE:/")
-	Subscribe(client, "META_DATA_CHANGE:/")
+func SubscribeDataChangeTest(client odb.Client) {
+	SubscribeTest(client, "CLASS_DATA_CHANGE:/")
+	SubscribeTest(client, "META_DATA_CHANGE:/")
 }
 
-func Subscribe(client odb.Client, topic string) {
+func SubscribeTest(client odb.Client, topic string) {
 	sub := client.Subscribe(context.Background(), topic)
 	go func() {
 		defer func() {