private void processAll(String cmd, Event event, HttpServletResponse response) {
        LOG.info("start to processAll admin task:{}", cmd);
        StringBuilder result = new StringBuilder();
        try {
            String beanName = JMX_DOMAIN + DOMAIN_SEPARATOR
                    + JMX_TYPE + PROPERTY_EQUAL + MBEAN_TYPE + PROPERTY_SEPARATOR
                    + "*";
            ObjectName objName = new ObjectName(beanName.toString());
            final MBeanServer mbs = ManagementFactory.getPlatformMBeanServer();
            Set<ObjectInstance> mbeans = mbs.queryMBeans(objName, null);
            LOG.info("queryMBeans for type:{},result:{}", MBEAN_TYPE, mbeans);
            for (ObjectInstance mbean : mbeans) {
                ObjectName beanObjectName = mbean.getObjectName();
                String className = mbean.getClassName();
                Class<?> clazz = ClassUtils.getClass(className);
                if (ClassUtils.isAssignable(clazz, ConsumerServiceMBean.class)) {
                    mbs.invoke(mbean.getObjectName(), cmd, null, null);
                    result.append(String.format("Execute command:%s success in bean:%s\n",
                            cmd, beanObjectName.toString()));
                }
            }
            this.outputResponse(response, result.toString());
        } catch (Exception e) {
            LOG.error(e.getMessage(), e);
            this.outputResponse(response, result.toString());
        }
        LOG.info("end to processAll admin task:{}", cmd);
    }
processAll

@param cmd
@param event
@param response
inlong-sort-standalone/sort-standalone-source/src/main/java/org/apache/inlong/sort/standalone/admin/ConsumerServiceAdminEventHandler.java