gistfile1.txt

receive(){
  //Arrow function to not change this context
  return new Promise((resolve, reject) => {
      let params = {
          QueueUrl: this.url,
          WaitTimeSeconds: this.waitTimeSeconds,
          MaxNumberOfMessages: this.maxNumberOfMessages,
          MessageAttributeNames: [
              'reprocess'
          ]
      };

      console.log(`(${this.url}) GETTING MESSAGES...`);
      this.SQS.receiveMessage(params, (err, data) => {
          if(err) return reject(err);

          console.log('Message', util.inspect(data, false, null));
          if (data !== null && data.Messages && data.Messages.length > 0) {
              console.log('RESOLVING...');
              return resolve(data);
          }

          //Try again
          this.receive();
      });
  });
}