Azure + Node Jsサービスバストピックの永続サブスクリプション

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

あなたはAzureのチームによって提供さGitHubで同様のシナリオでのサンプルコードを参照することができます。

さらに詳しいことがありましたら、お気軽にお知らせください。