java/e2e-spring/src/main/java/org/apache/rocketmq/utils/MQAdmin.java [55:69]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
public class MQAdmin {
    private static final Logger log = LoggerFactory.getLogger(MQAdmin.class);
    public static DefaultMQAdminExt mqAdminExt;

    public static DefaultMQAdminExt initMQAdminExtInstance(String namesrvAddr) {
        mqAdminExt = new DefaultMQAdminExt();
        mqAdminExt.setInstanceName(UUID.randomUUID().toString());
        mqAdminExt.setNamesrvAddr(namesrvAddr);
        try {
            mqAdminExt.start();
        } catch (MQClientException e) {
            e.printStackTrace();
            System.exit(-1);
        }
        return mqAdminExt;
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



java/e2e-v4/src/main/java/org/apache/rocketmq/utils/MQAdmin.java [36:50]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
public class MQAdmin {
    private static final Logger log = LoggerFactory.getLogger(MQAdmin.class);
    public static DefaultMQAdminExt mqAdminExt;

    public static DefaultMQAdminExt initMQAdminExtInstance(String namesrvAddr) {
        mqAdminExt = new DefaultMQAdminExt();
        mqAdminExt.setInstanceName(UUID.randomUUID().toString());
        mqAdminExt.setNamesrvAddr(namesrvAddr);
        try {
            mqAdminExt.start();
        } catch (MQClientException e) {
            e.printStackTrace();
            System.exit(-1);
        }
        return mqAdminExt;
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -