namespace WIDESEAWCS_RedisService.PubSub
{
    public interface IMessageQueueService
    {
        /// <summary>
        /// 发布消息
        /// </summary>
        long Publish(string channel, string message);

        /// <summary>
        /// 订阅频道
        /// </summary>
        void Subscribe(string channel, Action<string, string> handler);

        /// <summary>
        /// 取消订阅
        /// </summary>
        void Unsubscribe(string channel);

        /// <summary>
        /// 推送消息到可靠队列（List）
        /// </summary>
        long Enqueue(string queueName, string message);

        /// <summary>
        /// 从可靠队列弹出消息
        /// </summary>
        string? Dequeue(string queueName, TimeSpan? timeout = null);

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