package cn.iocoder.yudao.module.iot.core.messagebus.core;

/**
 * IoT 消息总线接口
 *
 * 用于在 IoT 系统中发布和订阅消息，支持多种消息中间件实现
 *
 * @author 芋道源码
 */
public interface IotMessageBus {

    /**
     * 发布消息到消息总线
     *
     * @param topic 主题
     * @param message 消息内容
     */
    void post(String topic, Object message);

    /**
     * 注册消息订阅者
     *
     * @param subscriber 订阅者
     */
    void register(IotMessageSubscriber<?> subscriber);

    /**
     * 取消注册消息订阅者
     *
     * @param subscriber 订阅者
     */
    default void unregister(IotMessageSubscriber<?> subscriber) {
        // TODO 芋艿：暂时不实现，需求量不大，但是
        // throw new UnsupportedOperationException("取消注册消息订阅者功能，尚未实现");
    }

}