package com.walker.async;
|
|
import java.util.List;
|
|
/**
|
* 生产者接口定义，对于想异步处理发送、接收数据的场景可以使用该方式。</p>
|
* 如：日志异步记录、公告查看异步记录等场景中。
|
* @author Administrator
|
*
|
*/
|
public interface Producer {
|
|
/**
|
* 生成一条数据，或者发送一条数据
|
* @param key 发送到的队列名称
|
* @param data 发送数据
|
* @param parameter 其他必要参数
|
* @throws ProduceException
|
*/
|
@Deprecated
|
void product(String key, Object data, Object parameter) throws ProduceException;
|
|
/**
|
* 批量向redis发送数据集合
|
* @param key 发送到的队列名称
|
* @param datas 发送的集合
|
* @param parameter 其他必要参数
|
* @throws ProduceException
|
*/
|
void push(String key, List<String> datas, Object parameter) throws ProduceException;
|
|
void push(String key, String data, Object parameter) throws ProduceException;
|
|
/**
|
* 清空给定的队列数据
|
* @param key
|
* @return
|
*/
|
long clearQueueData(String key);
|
}
|
