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