package com.epmet.mq;

import com.epmet.commons.rocketmq.constants.ConsomerGroupConstants;
import com.epmet.commons.rocketmq.constants.TopicConstants;
import com.epmet.commons.rocketmq.register.MQAbstractRegister;
import com.epmet.commons.rocketmq.register.MQConsumerProperties;
import com.epmet.mq.listener.ICWarnStatsEventListener;
import org.apache.rocketmq.common.protocol.heartbeat.MessageModel;
import org.springframework.stereotype.Component;

/**
 * @Description 如果rocketmq.enable=true，这里必须实现，且 实例化
 * @author wxz
 * @date 2021.07.14 17:13:41
*/
@Component
public class RocketMQWarnStatsRegister extends MQAbstractRegister {

    @Override
    public void registerAllListeners(String env, MQConsumerProperties consumerProperties) {
        // 客户初始化监听器注册
        register(consumerProperties,
                ConsomerGroupConstants.IC_WARN_STATS_EVENT_LISTENER_GROUP,
                MessageModel.CLUSTERING,
                TopicConstants.IC_RESI_USER,
                "*",
                new ICWarnStatsEventListener());

        // ...其他监听器类似
    }
}