Microservice/pqs
5
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases 1 Wiki Activity

增加消息处理异常记录--system模块

Browse Source
This commit is contained in:
hongawen
2023-08-18 09:48:19 +08:00
parent d3847c4b1f
commit 4e55237f4c
11 changed files with 235 additions and 66 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
pqs-common/common-mq/src/main/java/com/njcn/mq/constant/BusinessTopic.java
View File

@@ -7,11 +7,6 @@ package com.njcn.mq.constant;
*/
public interface BusinessTopic {
/***
* 测试阶段用的用户主题
*/
String NJCJ_USER_TOPIC = "njcnUserTopic";
/**
* 治理主送推送数据接收主题
*/

23
pqs-common/common-mq/src/main/java/com/njcn/mq/message/UserMessage.java
View File

@@ -1,23 +0,0 @@
package com.njcn.mq.message;
import com.njcn.middle.rocket.domain.BaseMessage;
import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.EqualsAndHashCode;
import lombok.NoArgsConstructor;
import java.time.LocalDate;
/**
* @author hongawen
* @version 1.0.0
* @date 2023年08月10日 14:45
*/
@Data
@EqualsAndHashCode(callSuper = true)
@AllArgsConstructor
@NoArgsConstructor
public class UserMessage extends BaseMessage {
private String userName;
private LocalDate birthday;
}

38
pqs-common/common-mq/src/main/java/com/njcn/mq/template/UserMessageTemplate.java
View File

@@ -1,38 +0,0 @@
package com.njcn.mq.template;
import com.njcn.middle.rocket.template.RocketMQEnhanceTemplate;
import com.njcn.mq.constant.BusinessTopic;
import com.njcn.mq.message.UserMessage;
import org.apache.rocketmq.client.producer.SendResult;
import org.apache.rocketmq.spring.core.RocketMQTemplate;
import org.springframework.stereotype.Component;
import java.time.LocalDate;
import java.util.UUID;
/**
* @author hongawen
* @version 1.0.0
* @date 2023年08月10日 14:44
*/
@Component
public class UserMessageTemplate extends RocketMQEnhanceTemplate {
public UserMessageTemplate(RocketMQTemplate template) {
super(template);
}
/**
* 入参只需要传入是哪个订单号和业务体消息即可，其他操作根据需要处理
* 这样对于调用者而言，可以更加简化调用
*/
public SendResult sendMember(String userName, LocalDate birthday) {
UserMessage message = new UserMessage();
message.setKey(UUID.randomUUID().toString());
message.setUserName(userName);
message.setBirthday(birthday);
return send(BusinessTopic.NJCJ_USER_TOPIC, "CREATE", message);
}
}