郑永安
2023-06-19 7a6abd05683528032687c75e80e0bd2030a3e46c
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
package com.gkhy.safePlatform.specialWork.mq.service;
 
import com.gkhy.safePlatform.specialWork.mq.msg.AnalysisExpireMsg;
import org.apache.rocketmq.client.producer.SendResult;
 
public interface WorkAnalysisProducerService {
 
 
    /**
    * @Description: 发送分析数据过期的消息
    */
    SendResult syncSendWorkExpireMsg(AnalysisExpireMsg message);
 
    SendResult syncSendWorkExpireMsgDelay(AnalysisExpireMsg message, int delayLevel);
 
}