Fiz a mesma pergunta há alguns dias:Não foi possível "espreitar" as mensagens de uma Fila de Barramento de Serviço do Azure usando AMQP e Nó. Estou fazendo a mesma pergunta novamente, mas com algumas diferenças (portanto, não marque esta pergunta como uma duplicata da outra pergunta):

Na pergunta anterior, eu estava usandonodeamqp10 biblioteca, no entanto, com base em alguns comentários na página do Github para essa biblioteca, acabei usandorhea ao invés denodeamqp10 biblioteca.Com alguma ajuda da equipe do Azure Service Bus, fiz alguns progressos e agora estou recebendo um erro de volta do Azure Service Bus que me diz que estou no caminho certo.

Aqui está o novo código que estou usando:

var client = require('rhea');
const keyName = 'MyCustomPolicy';
const sasKey = 'SAS Key'
const serviceBusHost = 'account.servicebus.windows.net';
const queueName = '003';

client.on('connection_open', (context) => {
  context.connection.open_sender({
    target: { address: `${queueName}/$management` }
  });
});

client.once('sendable', (context) => {
  console.log('messages can be sent now....');
  var receiver = context.connection.open_receiver({
    source: { address: `${queueName}/$management` },
    autoaccept: false,
    target: { address: 'receiver-link' }
  });

  receiver.once('receiver_open', (context) => {
    console.log('receiver is now open....');
  });

  receiver.once('message', (context) => {
    console.log('message received by receiver....');
    console.log(context.message);
  });

  var messageBody = {
    'from-sequence-number': 1,
    'message-count': 5
  };

  const msg = {
    application_properties: {
      operation: 'com.microsoft:peek-message'
    },
    body: client.types.wrap_map(messageBody),
    reply_to: 'receiver-link'
  };
  context.sender.send(msg);
  console.log('message sent....');
});

client.connect({
  transport: 'tls',
  host: serviceBusHost,
  hostname: serviceBusHost,
  username: keyName,
  password: sasKey,
  port: 5671,
  reconnect_limit: 10
});

Agora, quando executo esse código, estou recebendo500 erro de volta do Barramento de Serviço do Azure:

{
  "application_properties":
  {
    "statusCode":500,
    "errorCondition":"amqp:internal-error",
    "statusDescription":"The service was unable to process the request; please retry the operation. For more information on exception types and proper exception handling, please refer to http://go.microsoft.com/fwlink/?LinkId=761101 Reference:ab667ed6-1565-4728-97b7-6ae4a33468b9, TrackingId:538f93a1-2c07-4bc0-bf41-dc00d7ae963c_B13, SystemTracker:account-name:Queue:003, Timestamp:8/2/2018 7:43:52 AM",
    "com.microsoft:tracking-id":"538f93a1-2c07-4bc0-bf41-dc00d7ae963c_B13"
  }
}

Até chequei o link incluído na mensagem de erro (http://go.microsoft.com/fwlink/?LinkId=761101), mas não há menção de erros relacionados ao amqp nesse link.

Como na pergunta anterior, se eu usar o endereço apenas como o nome da fila em vez dequeue-name/$management, Sou capaz de receber as mensagens, mas as mensagens estão bloqueadas e a contagem de entrega das mensagens está aumentando. Além disso, está retornando todas as mensagens da fila em vez de apenas 5 mensagens que estou solicitando.

Não tenho certeza do que estou fazendo de errado. Alguém pode ajudar?