receiver.on('message', function (message) {
      console.log('received: ', message.body);
      if (message.annotations) console.log('annotations: ', message.annotations);
      if (message.body.DataValue === msgVal) {
        client.disconnect().then(function () {