class AliyunOnsRocketMqAdapter extends AbstractDtpAdapter {

    private static final String TP_PREFIX = "rocketMqTp";

    private static final String CONSUME_EXECUTOR_FIELD = "consumeExecutor";

    @Override
    public void refresh(DtpProperties dtpProperties) {
        refresh(dtpProperties.getRocketMqTp(), dtpProperties.getPlatforms());
    }

    @Override
    protected String getTpPrefix() {
        return TP_PREFIX;
    }

    @Override
    protected void initialize() {
        super.initialize();
        adaptConsumerExecutors();
    }

    private void adaptConsumerExecutors() {
        // get consumer beans
        val beans = ApplicationContextHolder.getBeansOfType(Consumer.class);
        if (MapUtils.isEmpty(beans)) {
            log.warn("Cannot find beans of type Consumer.");
            return;
        }
        beans.forEach(this::accept);
    }

    private void accept(String k, Consumer v) {<FILL_FUNCTION_BODY>}
}

        val consumer = (ConsumerImpl) v;
        val defaultMqPushConsumer = (DefaultMQPushConsumer) ReflectionUtil.getFieldValue(
                ConsumerImpl.class, "defaultMQPushConsumer", consumer);
        if (Objects.isNull(defaultMqPushConsumer)) {
            return;
        }
        val impl = (DefaultMQPushConsumerImpl) ReflectionUtil.getFieldValue(
                DefaultMQPushConsumer.class, "defaultMQPushConsumerImpl", defaultMqPushConsumer);
        if (Objects.isNull(impl)) {
            return;
        }

        val consumeMessageService = impl.getConsumeMessageService();
        String tpName = defaultMqPushConsumer.getConsumerGroup();
        if (consumeMessageService instanceof ConsumeMessageConcurrentlyService) {
            tpName = TP_PREFIX + "#consumer#concurrently#" + tpName;
        } else if (consumeMessageService instanceof ConsumeMessageOrderlyService) {
            tpName = TP_PREFIX + "#consumer#orderly#" + tpName;
        }
        ThreadPoolExecutor executor = (ThreadPoolExecutor) ReflectionUtil.getFieldValue(CONSUME_EXECUTOR_FIELD, consumeMessageService);
        if (Objects.nonNull(executor)) {
            enhanceOriginExecutor(tpName, executor, CONSUME_EXECUTOR_FIELD, consumeMessageService);
        }
    
<methods>public non-sealed void <init>() ,public Map<java.lang.String,org.dromara.dynamictp.core.support.ExecutorWrapper> getExecutorWrappers() ,public List<org.dromara.dynamictp.common.entity.ThreadPoolStats> getMultiPoolStats() ,public void refresh(List<org.dromara.dynamictp.common.entity.TpExecutorProps>, List<org.dromara.dynamictp.common.entity.NotifyPlatform>) ,public void refresh(org.dromara.dynamictp.core.support.ExecutorWrapper, List<org.dromara.dynamictp.common.entity.NotifyPlatform>, org.dromara.dynamictp.common.entity.TpExecutorProps) <variables>private static final Equator EQUATOR,protected final Map<java.lang.String,org.dromara.dynamictp.core.support.ExecutorWrapper> executors