$scope.openCreateOrUpdateDialog = function()

in src/main/resources/static/src/consumer.js [253:298]


    $scope.openCreateOrUpdateDialog = function (request) {
        var bIsUpdate = true;
        if (request == null) {
            request = [{
                brokerNameList: [],
                subscriptionGroupConfig: {
                    groupName: "",
                    consumeEnable: true,
                    consumeMessageOrderly: false,
                    consumeFromMinEnable: true,
                    consumeBroadcastEnable: true,
                    retryQueueNums: 1,
                    retryMaxTimes: 16,
                    brokerId: 0,
                    whichBrokerWhenConsumeSlowly: 1
                }
            }];
            bIsUpdate = false;
        }
        console.log(request);
        $http({
            method: "GET",
            url: "cluster/list.query"
        }).success(function (resp) {
            if (resp.status == 0) {
                console.log(resp);
                ngDialog.open({
                    preCloseCallback: function (value) {
                        // Refresh topic list
                        $scope.queryConsumerData();
                    },
                    template: $scope.rmqVersion ? 'consumerModifyDialogForV5' : 'consumerModifyDialog',
                    controller: 'consumerModifyDialogController',
                    data: {
                        consumerRequestList: request,
                        allClusterNameList: Object.keys(resp.data.clusterInfo.clusterAddrTable),
                        allBrokerNameList: Object.keys(resp.data.brokerServer),
                        bIsUpdate: bIsUpdate,
                        writeOperationEnabled: $scope.writeOperationEnabled
                    }
                });
            } else {
                Notification.error({message: resp.errMsg, delay: 2000});
            }
        });
    };