java/e2e-v4/src/main/java/org/apache/rocketmq/utils/MQAdmin.java [40:51]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
    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-spring/src/main/java/org/apache/rocketmq/utils/MQAdmin.java [59:70]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
    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;
    }
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -