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);
|
|
}
|