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});
}
});
};