namespace WIDESEAWCS_RedisService.DelayQueue
{
    public interface IDelayQueueService
    {
        /// <summary>
        /// 添加延迟任务
        /// </summary>
        bool Enqueue(string queueName, string message, TimeSpan delay);

        /// <summary>
        /// 获取到期的任务
        /// </summary>
        List<string> DequeueDue(string queueName, int count = 10);

        /// <summary>
        /// 移除任务
        /// </summary>
        bool Remove(string queueName, string message);

        /// <summary>
        /// 获取队列长度
        /// </summary>
        long GetQueueLength(string queueName);
    }
}