You've already forked FrameTour-BE
feat(message): 移除ZT消息生产者示例代码- 删除ZtMessageProducerExample类及相关依赖
- 移除示例消息发送逻辑 - 清理无用的HashMap和日志记录代码 - 移除条件注解@ConditionalOnProperty配置 - 删除消息构建及发送示例实现
This commit is contained in:
@@ -1,33 +0,0 @@
|
||||
package com.ycwl.basic.integration.message.example;
|
||||
|
||||
import com.ycwl.basic.integration.message.dto.ZtMessage;
|
||||
import com.ycwl.basic.integration.message.service.ZtMessageProducerService;
|
||||
import lombok.RequiredArgsConstructor;
|
||||
import lombok.extern.slf4j.Slf4j;
|
||||
import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty;
|
||||
import org.springframework.stereotype.Component;
|
||||
|
||||
import java.util.HashMap;
|
||||
|
||||
@Slf4j
|
||||
@Component
|
||||
@RequiredArgsConstructor
|
||||
@ConditionalOnProperty(name = "kafka.example.zt-message.enabled", havingValue = "true", matchIfMissing = false)
|
||||
public class ZtMessageProducerExample {
|
||||
|
||||
private final ZtMessageProducerService producer;
|
||||
|
||||
public void demo() {
|
||||
log.info("=== ZT-Message Producer Example ===");
|
||||
|
||||
ZtMessage msg = ZtMessage.of("dummy", "标题", "内容", "user-001");
|
||||
var extra = new HashMap<String, Object>();
|
||||
extra.put("k", "v");
|
||||
msg.setExtra(extra);
|
||||
msg.setSendReason("REGISTER");
|
||||
msg.setSendBiz("USER");
|
||||
|
||||
producer.send(msg);
|
||||
log.info("ZT-Message produced");
|
||||
}
|
||||
}
|
Reference in New Issue
Block a user