From 4b2e5fe22c050ad36734fcb580141e0e1756ca63 Mon Sep 17 00:00:00 2001
From: xiandong <xiandong@italki.com>
Date: Fri, 23 Jun 2023 11:51:57 +0800
Subject: [PATCH] add dtmMsg.AddTopic

---
 event_bus_dtm.go | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/event_bus_dtm.go b/event_bus_dtm.go
index 9282a21..dc7e121 100644
--- a/event_bus_dtm.go
+++ b/event_bus_dtm.go
@@ -111,7 +111,7 @@ func (p *DtmEventProducer) Send(ctx context.Context, eventMessages ...DomainEven
 		fd := eventBody.ProtoReflect().Descriptor().Fields().ByName("abs")
 		fv := protoreflect.ValueOfMessage(abs.ProtoReflect())
 		eventBody.ProtoReflect().Set(fd, fv)
-		dtmMsg = dtmMsg.Add("localhost:8082/user_query.userQuery/insertUser", eventBody)
+		dtmMsg.AddTopic("create_user", eventBody)
 	}
 	dtmMsg.BranchHeaders = map[string]string{"test_header": "aaasdfa"}
 	dtmcli.SetBarrierTableName("myhubdb.barrier")