Hice la misma pregunta hace unos días:No se pueden "mirar" mensajes de una cola de bus de servicio de Azure con AMQP y el nodo. Estoy haciendo la misma pregunta nuevamente pero con algunas diferencias (por lo tanto, no marque esta pregunta como un duplicado de la otra pregunta):

En la pregunta anterior, estaba usandonodeamqp10 biblioteca, sin embargo, según algunos comentarios en la página de Github para esta biblioteca, terminé usandorhea en lugar denodeamqp10 biblioteca.Con la ayuda del equipo de Azure Service Bus, avancé un poco y ahora recibo un error de Azure Service Bus que me dice que estoy en el camino correcto.

Aquí está el nuevo código que estoy 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
});

Ahora cuando ejecuto este código, obtengo500 error de vuelta desde Azure Service Bus:

{
  "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"
  }
}

Incluso verifiqué el enlace incluido en el mensaje de error http: //go.microsoft.com/fwlink/? LinkId = 761101) pero no se mencionan los errores relacionados con amqp en ese enlace.

Como en la pregunta anterior, si uso la dirección solo como el nombre de la cola en lugar dequeue-name/$management, Puedo recibir los mensajes pero los mensajes están bloqueados y el recuento de entregas para los mensajes está aumentando. Además, está devolviendo todos los mensajes de la cola en lugar de solo 5 mensajes que estoy solicitando.

No estoy seguro de lo que estoy haciendo mal. ¿Alguien puede ayudar?