Skip to content

[ISSUE #393] Fix DLQ Message functionality in RocketMQ Dashboard #394

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Open
FaisalMisbah23 wants to merge 1 commit into
base: master
Choose a base branch
from
Open

[ISSUE #393] Fix DLQ Message functionality in RocketMQ Dashboard #394

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
1 commit
Select commit
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
16 changes: 15 additions & 1 deletion .gitignore
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -6,4 +6,18 @@
.factorypath
.settings/
.vscode
htmlReport/
htmlReport/

# Helper scripts and documentation (not part of codebase)
commit-and-push.sh
setup-pr.sh
stage-pr-files.sh
*_CHECKLIST.md
PR_*.md
CODE_REVIEW.md
ISSUES_*.md
MANUAL_TEST_*.md

# Log files
*.log
dashboard.log
93 changes: 67 additions & 26 deletions frontend-new/src/api/remoteApi/remoteApi.js
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -250,17 +250,12 @@ const remoteApi = {
}
},
resendDlqMessage: async (msgId, consumerGroup, topic) => {
topic = encodeURIComponent(topic);
consumerGroup = encodeURIComponent(consumerGroup);
msgId = encodeURIComponent(msgId);
try {
const response = await remoteApi._fetch(remoteApi.buildUrl("/message/consumeMessageDirectly.do"), {
const response = await remoteApi._fetch(remoteApi.buildUrl(`/dlqMessage/resendDlqMessage.do?msgId=${msgId}&consumerGroup=${consumerGroup}&topic=${topic}`), {
method: 'POST',
headers: {
'Content-Type': 'application/json',
},
params: {
msgId: msgId,
consumerGroup: consumerGroup,
topic: topic
},
});
const data = await response.json();
return data;
Expand All @@ -271,27 +266,29 @@ const remoteApi = {
},
exportDlqMessage: async (msgId, consumerGroup) => {
try {
const response = await remoteApi._fetch(remoteApi.buildUrl(`/dlqMessage/exportDlqMessage.do?msgId=${msgId}&consumerGroup=${consumerGroup}`));
const response = await remoteApi._fetch(remoteApi.buildUrl(`/dlqMessage/exportDlqMessage.do?msgId=${encodeURIComponent(msgId)}&consumerGroup=${encodeURIComponent(consumerGroup)}`));

if (!response.ok) {
throw new Error(`HTTP error! status: ${response.status}`);
}

const data = await response.json();

const newWindow = window.open('', '_blank');

if (!newWindow) {
return {status: 1, errMsg: "Failed to open new window. Please allow pop-ups for this site."};
}

newWindow.document.write('<html><head><title>DLQ 导出内容</title></head><body>');
newWindow.document.write('<h1>DLQ 导出 JSON 内容</h1>');
newWindow.document.write('<pre>' + JSON.stringify(data, null, 2) + '</pre>');
newWindow.document.write('</body></html>');
newWindow.document.close();

return {status: 0, msg: "导出请求成功，内容已在新页面显示"};
// The backend returns an Excel file (binary), not JSON
const blob = await response.blob();

// Create a download link
const url = window.URL.createObjectURL(blob);
const a = document.createElement('a');
a.href = url;
a.download = `dlq_message_${msgId}_${Date.now()}.xlsx`;
document.body.appendChild(a);
a.click();
// Delay URL revocation to prevent race condition
setTimeout(() => {
window.URL.revokeObjectURL(url);
document.body.removeChild(a);
}, 100);

return {status: 0, msg: "Export successful"};
} catch (error) {
console.error("Error exporting DLQ message:", error);
return {status: 1, errMsg: "Failed to export DLQ message: " + error.message};
Expand All @@ -307,11 +304,55 @@ const remoteApi = {
},
body: JSON.stringify(messages),
});

if (!response.ok) {
const errorText = await response.text();
console.error("Batch resend HTTP error:", response.status, errorText);
return {status: 1, errMsg: `HTTP error: ${response.status} - ${errorText}`};
}

const data = await response.json();
return data;
} catch (error) {
console.error("Error batch resending DLQ messages:", error);
return {status: 1, errMsg: "Failed to batch resend DLQ messages"};
return {status: 1, errMsg: "Failed to batch resend DLQ messages: " + error.message};
}
},

batchExportDlqMessage: async (messages) => {
try {
const response = await remoteApi._fetch(remoteApi.buildUrl("/dlqMessage/batchExportDlqMessage.do"), {
method: 'POST',
headers: {
'Content-Type': 'application/json',
},
body: JSON.stringify(messages),
});

if (!response.ok) {
throw new Error(`HTTP error! status: ${response.status}`);
}

// The backend returns an Excel file (binary), not JSON
const blob = await response.blob();

// Create a download link
const url = window.URL.createObjectURL(blob);
const a = document.createElement('a');
a.href = url;
a.download = `dlq_messages_${Date.now()}.xlsx`;
document.body.appendChild(a);
a.click();
// Delay URL revocation to prevent race condition
setTimeout(() => {
window.URL.revokeObjectURL(url);
document.body.removeChild(a);
}, 100);

return {status: 0, msg: "Batch export successful"};
} catch (error) {
console.error("Error batch exporting DLQ messages:", error);
return {status: 1, errMsg: "Failed to batch export DLQ messages: " + error.message};
}
},

Expand Down
8 changes: 7 additions & 1 deletion frontend-new/src/components/DlqMessageDetailViewDialog.jsx
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -50,14 +50,20 @@ const DlqMessageDetailViewDialog = ({ngDialogData}) => {
<Text strong>{messageView.properties?.TAGS}</Text>
</Form.Item>
<Form.Item label="Key:">
<Text strong>{messageView.properties?.KEYS}</Text>
<Text strong>{messageView.properties?.KEYS || '-'}</Text>
</Form.Item>
<Form.Item label="Storetime:">
<Text strong>{moment(messageView.storeTimestamp).format('YYYY-MM-DD HH:mm:ss')}</Text>
</Form.Item>
<Form.Item label="StoreHost:">
<Text strong>{messageView.storeHost}</Text>
</Form.Item>
<Form.Item label="BornHost:">
<Text strong>{messageView.bornHost || '-'}</Text>
</Form.Item>
<Form.Item label="BornTimestamp:">
<Text strong>{messageView.bornTimestamp ? moment(messageView.bornTimestamp).format('YYYY-MM-DD HH:mm:ss') : '-'}</Text>
</Form.Item>
<Form.Item label="Message body:">
<Input.TextArea
value={messageView.messageBody}
Expand Down
Loading