mirror of
https://github.com/apache/rocketmq-dashboard.git
synced 2025-09-12 22:18:27 +08:00
Co-authored-by: zhangjidi2016 <zhangjidi@cmss.chinamobile.com>
This commit is contained in:
@@ -187,6 +187,9 @@ module.controller('dlqMessageController', ['$scope', 'ngDialog', '$http', 'Notif
|
|||||||
|
|
||||||
$scope.selectedDlqMessage = [];
|
$scope.selectedDlqMessage = [];
|
||||||
$scope.batchResendDlqMessage = function (consumerGroup) {
|
$scope.batchResendDlqMessage = function (consumerGroup) {
|
||||||
|
if ($("#batchResendBtn").hasClass("disabled")) {
|
||||||
|
return;
|
||||||
|
}
|
||||||
for (const message of $scope.messageCheckedList) {
|
for (const message of $scope.messageCheckedList) {
|
||||||
const dlqMessage = {};
|
const dlqMessage = {};
|
||||||
dlqMessage.topic = message.properties.RETRY_TOPIC;
|
dlqMessage.topic = message.properties.RETRY_TOPIC;
|
||||||
@@ -219,6 +222,9 @@ module.controller('dlqMessageController', ['$scope', 'ngDialog', '$http', 'Notif
|
|||||||
};
|
};
|
||||||
|
|
||||||
$scope.batchExportDlqMessage = function (consumerGroup) {
|
$scope.batchExportDlqMessage = function (consumerGroup) {
|
||||||
|
if ($("#batchExportBtn").hasClass("disabled")) {
|
||||||
|
return;
|
||||||
|
}
|
||||||
for (const message of $scope.messageCheckedList) {
|
for (const message of $scope.messageCheckedList) {
|
||||||
const dlqMessage = {};
|
const dlqMessage = {};
|
||||||
dlqMessage.msgId = message.msgId;
|
dlqMessage.msgId = message.msgId;
|
||||||
|
Reference in New Issue
Block a user