如何解决NodeJS @ azure / service-bus:有任何手动将消息发送到死信的示例吗?
我找不到任何示例来手动将消息发送到死信队列。
let { ServiceBusClient,ReceiveMode } = require('@azure/service-bus'),serviceBusClient = ServiceBusClient.createFromConnectionString(SERVICE_BUS_SECRET),queueClient = serviceBusClient.createQueueClient(QUEUE),receiver = queueClient.createReceiver(ReceiveMode.peekLock);
const onMessageHandler = async (brokeredMessage) => {
await brokeredMessage.deadletter({
deadletterReason: 'testingReason',deadLetterErrorDescription: 'testingDesc'
});
};
const onErrorHandler = (error) => {
console.log(error);
};
receiver.registerMessageHandler(onMessageHandler,onErrorHandler);
运行上述代码时,出现类似deadletter() is not defined.
解决方法
关于此问题,请参考以下代码
async function main() {
const sbClient = ServiceBusClient.createFromConnectionString(
connectionString
);
const queueClient = sbClient.createQueueClient(queueName);
try {
const receiver = queueClient.createReceiver(ReceiveMode.peekLock);
const receiverPromise = new Promise((resolve,_reject) => {
const onMessageHandler = async (brokeredMessage) => {
console.log("Received message: ",brokeredMessage.messageId);
await brokeredMessage.deadLetter({
deadletterReason: "test",deadLetterErrorDescription: "test",});
console.log(
`send message ${brokeredMessage.messageId} to dead letter queue successfully `
);
};
const onErrorHandler = (err) => {
if (err.retryable === true) {
console.log(
"Receiver will be recreated. A recoverable error occurred:",err
);
resolve();
} else {
console.log("Error occurred: ",err);
}
};
receiver.registerMessageHandler(onMessageHandler,onErrorHandler,{
autoComplete: false,});
});
await receiverPromise;
await receiver.close();
} finally {
await queueClient.close();
await sbClient.close();
}
}
main().catch((err) => {
console.log("Error occurred: ",err);
});
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。