Azure + Node Js Service bus Постоянная подписка на тему

Question

Использование узла js Я хочу создать постоянную подписку на тему обслуживания сервисной шины Azure. сейчас он выполняется только один раз. Пожалуйста, назовите меня, я новичок в этом. Заранее спасибо. Я использую следующий код для подписки на тему.

var azure = require('azure'); 

var azureConnection = "Endpoint=sb:My connection string" 

var retryOperations = new azure.ExponentialRetryPolicyFilter(); 
var serviceBusService = azure.createServiceBusService(azureConnection).withFilter(retryOperations); 

serviceBusService.receiveSubscriptionMessage('mytopic01', 'mytopicsub', function (error, receivedMessage) { 

    if (!error) { 
     // // // Message received and deleted 
     console.log(receivedMessage); 
    } 
}); 

Также я не хочу использовать функцию setInterval. Я хочу, чтобы решение, если сообщение опубликовано в теме, должно автоматически запускать подписку.

Answer 1

На самом деле, если ваше клиентское приложение является независимым приложением node.js, мы обычно настраиваем программу цикла для приема сообщения из служебной шины в цикле. E.G.

var azure = require('azure'); 
var sbService = azure.createServiceBusService(<connection_string>); 
function checkForMessages(sbService, queueName, callback) { 
    sbService.receiveSubscriptionMessage(queueName, { isPeekLock: true }, function (err, lockedMessage) { 
    if (err) { 
     if (err === 'No messages to receive') { 
     console.log('No messages'); 
     } else { 
     callback(err); 
     } 
    } else { 
     callback(null, lockedMessage); 
    } 
    }); 
} 
function processMessage(sbService, err, lockedMsg) { 
    if (err) { 
    console.log('Error on Rx: ', err); 
    } else { 
    console.log('Rx: ', lockedMsg); 
    sbService.deleteMessage(lockedMsg, function(err2) { 
     if (err2) { 
     console.log('Failed to delete message: ', err2); 
     } else { 
     console.log('Deleted message.'); 
     } 
    }) 
    } 
} 
setInterval(checkForMessages.bind(null, sbService, queueName, processMessage.bind(null, sbService)), 5000); 

Вы можете обратиться к образцу кода в аналогичном сценарии в GitHub предоставленной Azure Team.

Любая дополнительная забота, пожалуйста, сообщите мне.