如何调用 Azure 服务总线队列 queueService.peekMessages()？

Question

我试着关注这个http://www.windowsazure.com/en-us/documentation/articles/storage-nodejs-how-to-use-queues/

我的代码：-

var AZURE = require('azure');

function TestQueue(QueueName)
{
    var queueService = AZURE.createQueueService(); // error occurred at this line 
    queueService.createQueueIfNotExists(QueueName, function(error){
        if(!error)
        {
            console.log("ok");
            RESPONSE.send(200, { Message: "ok", Status: "ok" });
        }
        else
        {
            console.log("error: "+error);
            RESPONSE.send(200, { Message: "error", Status: "error" });
        }
    });
}

错误信息：-

错误信息：-

NoMatchError: 提供的设置 {"blobendpoint":"https://undefined.blob.core.windows.net","tableendpoint":"https://undefined.table.core.windows.net","queueendpoint":"https://undefined.queue.core.windows.net"} 不完整。

请注意，有 azure 存储队列和 azure 服务总线队列。我需要服务总线队列。这样我就可以调用 queueService.peekMessages()。我的目标是在不从队列中删除消息的情况下获取队列消息。

我在另一个线程@Error when call azure.createQueueService() 中问了同样的问题，它与 2 个不同的队列内容混合在一起。最终我没有得到我的答案。这次希望得到答案。提前感谢！

Answer 1

var azure = require('azure');

var namespace = 'YOUR-NAMESPACE-GOES-HERE';
var key = 'YOUR-KEY-GOES-HERE';
var issuer = 'owner'
var acs = namespace + '-sb';
var host = namespace + '.servicebus.windows.net';
var authProv = null;
var serviceBusService = azure.createServiceBusService(namespace, key, issuer, acs, host, authProv);
var queueName = 'nodequeue';

console.log('Connecting...');
serviceBusService.createQueueIfNotExists(queueName, function(error){

  if(error){
    console.log('ERROR: ' + error);
    return;
  }

  console.log('Connected, receiving...');

  serviceBusService.receiveQueueMessage(queueName,  { isPeekLock: true },function(error, msg){

    if(error){
      console.log('ERROR: ' + error);
      return;
    }

    console.log('Received:');
    console.dir(msg);

  });

});

来源：https://gist.github.com/hectorcorrea/7372111