package cn.axzo.workflow.starter.mq.monitor;

import org.apache.rocketmq.tools.admin.DefaultMQAdminExt;

/**
 * 用于监控 Starter 关注的 Topic 相关的 Producer 与 Consumer 信息
 *
 * @author wangli
 * @since 2024/6/6 10:04
 */
public class WorkflowEngineStarterDefaultMQMonitor {

    private final DefaultMQAdminExt defaultMQAdminExt;

    public WorkflowEngineStarterDefaultMQMonitor(DefaultMQAdminExt defaultMQAdminExt) {
        this.defaultMQAdminExt = defaultMQAdminExt;
    }
}
