Docker NodeJS, время ожидания блокировки службы Azure ServiceBus

Помимо изменения параметра «Длительность блокировки» на портале Azure, я хочу знать, как установить значение тайм-аута / механизм возобновления блокировки. (Лучше обрабатывать неизвестные длительные задачи)

var azure = require('azure-sb'),
    serviceBusService = azure.createServiceBusService("Endpoint=XXX");
serviceBusService.receiveQueueMessage(MESSAGE_QUEUE_NAME, { isPeekLock: true }, function(error, lockedMessage){
... task running longer than "Lock Duration" ...
}

По завершении появляется ошибка, и сообщение перемещается в очередь недоставленных писем:

Ошибка: 404 - поставленная блокировка недействительна. Либо срок блокировки истек, либо сообщение уже удалено из очереди.


person DaiKeung    schedule 20.11.2018    source источник


Ответы (1)


Вы можете попробовать и использовать refreshLockForMessage, чтобы продлить блокировку.

Надеюсь, это поможет!

person Itay Podhajcer    schedule 20.11.2018