package com.ks.lucky.service;
|
|
import com.ks.lucky.exception.LuckyMQException;
|
import com.ks.lucky.pojo.DO.LuckyMQ;
|
|
import java.util.Date;
|
import java.util.List;
|
|
public interface LuckyMQService {
|
|
/**
|
* 添加消息
|
*
|
* @param mq
|
* @throws LuckyMQException
|
*/
|
public void addMQ(LuckyMQ mq) throws LuckyMQException;
|
|
|
/**
|
* 获取当前未发送的消息列表
|
*
|
* @param now
|
* @param page
|
* @param pageCount
|
*/
|
public List<LuckyMQ> listUnSendMsg(Date now, int page, int pageCount);
|
|
/**
|
* 未发送消息计数
|
*
|
* @param now
|
*/
|
public long countUnSendMsg(Date now);
|
|
|
/**
|
* 移除未发送的消息
|
*
|
* @param taskId
|
*/
|
public void removeUnSendMsg(String taskId) throws LuckyMQException;
|
|
|
/**
|
* 发送消息
|
*
|
* @param taskId
|
*/
|
public void sendMsg(String taskId) throws LuckyMQException;
|
|
|
}
|
