public void getSubConnection()

in java/e2e-v4/src/main/java/org/apache/rocketmq/utils/MQAdmin.java [162:179]

• 17 lines of code
• 4 McCabe index (conditional complexity)

    public void getSubConnection(String nameSrvAddr, String clusterName, String consumerId) {
        SubscriptionGroupConfig config = new SubscriptionGroupConfig();
        config.setGroupName(consumerId);
        try {
            Set<String> masterSet = CommandUtil.fetchMasterAddrByClusterName(mqAdminExt, clusterName);
            for (String addr : masterSet) {
                try {

                    System.out.printf("create subscription group %s to %s success.\n", consumerId, addr);
                } catch (Exception e) {
                    e.printStackTrace();
                    Thread.sleep(1000 * 1);
                }
            }
        } catch (Exception e) {
            e.printStackTrace();
        }
    }