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