const
    protocol = settings.protocol || 'amqps',
    serviceBusHost = settings.serviceBusHost.indexOf(".") !== -1 ?
        settings.serviceBusHost :
        settings.serviceBusHost + '.servicebus.windows.net',

    sasName = settings.SASKeyName,
    sasKey = settings.SASKey,
    topicName = settings.topicName,
    subscriptionName = settings.subscriptionName,

    uri = protocol + '://' + encodeURIComponent(sasName) + ':' + encodeURIComponent(sasKey) + '@' + serviceBusHost,

    msgVal = Math.floor(Math.random() * 1000000),

    client = new amqp.Client(amqp.Policy.ServiceBusTopic);

client.connect(uri)
    .then(() => Promise.all([
        client.createSender(topicName),
        client.createReceiver(topicName + '/Subscriptions/' + subscriptionName)
    ]))
    .then(([sender, receiver]) => {
        // error handling
        sender.on('errorReceived', tx_err => { console.warn('===> TX ERROR: ', tx_err); });
        receiver.on('errorReceived', rx_err => { console.warn('===> RX ERROR: ', rx_err); });

        // message event handler
        receiver.on('message', message => {
            console.log('received: ', message);

function createPartitionReceiver(curIdx: number, curRcvAddr: string, filterOption: amqp.Policy.Options.ReceiverLink) {
    return client.createReceiver(curRcvAddr, filterOption)
        .then(receiver => {
            receiver.on('message', messageHandler.bind(null, curIdx));
            receiver.on('errorReceived', errorHandler.bind(null, curIdx));
        });
};

 .then(function() {
   console.log("THEN");
   return Promise.all([
     client.createReceiver('fhir_datasync_queue_dev', { auto_delete: true })
     //client.createSender('fhir_datasync_queue_dev')
   ]);
 })

    receiver.on('message', msg => {
      console.log('Message received: ');
      console.log('Number of partitions: ' + msg.body.partition_count);
      console.log('Partition IDs: ' + msg.body.partition_ids);

      client.disconnect().then(() => {
        console.log('=== Disconnected ===');
        process.exit(0);
      });
    });

        receiver.on('message', message => {
            console.log('received: ', message);

            if (message.body.DataValue === msgVal) {
                client.disconnect().then(() => {
                    console.log('disconnected, when we saw the value we inserted.');
                    process.exit(0);
                });
            }
        });

function messageHandler(myIdx: number, msg: amqp.Message) {
    console.log('received(' + myIdx + '): ', msg.body);

    if (msg.annotations)
        console.log('annotations: ', msg.annotations);

    if (msg.body.DataValue === msgVal) {
        client.disconnect().then(() => {
            console.log('disconnected, when we saw the value we inserted.');
            process.exit(0);
        });
    }
}

    receiver.on('message', message => {
      console.log('received: ', message.body);

      if (message.annotations)
        console.log('annotations: ', message.annotations);

      if (message.body.dataValue === msgId) {
        client.disconnect().then(() => {
          console.log('received expected message, disconnected.');
          process.exit(0);
        });
      }
    });

 connect() {
     console.log('CONNECTING..');
     return this.client.connect('amqp://apollo:ollopaehcapa@localhost')
         .then(() => {
             console.log('CONNECTION OK');
             return Promise.all([this.client.createReceiver('jms.queue.toto'), this.client.createSender('jms.queue.toto')])
         })
         .then(results => {
             this.receiverDefer.resolve(results[0]);
             this.senderDefer.resolve(results[1]);
         })
         .catch(err => {
             console.log("error: ", err);
         });
 }

 .then(() => Promise.all([
     client.createReceiver('amq.topic'),
     client.createSender('amq.topic')
 ]))