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

}