feat:增加事务重载方法

This commit is contained in:
zhanglei 2023-10-16 14:34:29 +08:00
parent a50a9bdb0e
commit 5ca2c2c4c7

View File

@ -108,6 +108,10 @@ public class EventProduceTemplate {
.operatorId("operatorId").data(message).build(), content);
}
public void send(String topic, String module, String name, Serializable message, String shardingKey, String targetId, String targetType, String tag) {
send(topic, module, name, message, shardingKey, targetId, targetType, tag, false);
}
private void checkParam(String topic, Object message) {
Objects.requireNonNull(topic, "topic not null");
Objects.requireNonNull(message, "message not null");