package xtools.boot.mq.base.handle;

/**
 * <p>Title : BaseMqHandle</p>
 * <p>Description : BaseMqHandle</p>
 * <p>DevelopTools : Idea_x64_v2026.1</p>
 * <p>DevelopSystem : macOS Sequoia 15.7.5</p>
 * <p>Company : org.xujun</p>
 *
 * @author : XuJun
 * @version : 5.0.0
 * @date : 2026/2/12 09:23
 */
public interface BaseMqHandle {

    /**
     * 初始化消息队列
     *
     * @param queueName 消息队列名称
     */
    void initQueue(String queueName);

    /**
     * 添加消息队列监听
     *
     * @param queueName      消息队列
     * @param delegate       监听类
     * @param listenerMethod 监听方法
     * @param params         参数
     */
    void addListen(String queueName, Object delegate, String listenerMethod, Object params);

    /**
     * 推送消息
     *
     * @param routingKey 路由 key
     * @param data       消息数据
     */
    void push(String routingKey, Object data);

}
