add dtmMsg.AddTopic

wuyazi · Jun 23, 2023 · 4b2e5fe · 4b2e5fe
1 parent 2e0dad9
commit 4b2e5fe
Showing 1 changed file with 1 addition and 1 deletion.
diff --git 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")