xiugai

rpc/biservice.go

@@ -33,7 +33,7 @@ func main() {
 	entity.InitArea()
 	//nsq
 	config := nsq.NewConfig()
-	consumer, err := nsq.NewConsumer(c.TopicName, "position_sync", config)
+	consumer, err := nsq.NewConsumer(c.TopicName, "jy_position_sync", config)
 	if err != nil {
 		fmt.Println(err)
 	}