Проверить входящее сообщение в aws sqs

Question

Как моя функция постоянно проверяет наличие входящего сообщения? После получения сообщения завершается следующая функция. Учитывая, что длительный опрос включен для очереди, как я могу постоянно проверять наличие нового сообщения?

function checkMessage(){ 
    var params = { 
       QueueUrl : Constant.QUEUE_URL, 
       VisibilityTimeout: 0, 
       WaitTimeSeconds: 0 
      } 
    sqs.receiveMessage(params,(err,data) => { 
     if(data){ 
      console.log("%o",data); 
     } 
    }); 
} 

Answer 1

Ваша функция должна будет постоянно опробовать Amazon SQS.

Длительный опрос задерживает ответ на 20 секунд, если сообщений нет. Если сообщение становится доступным в течение этого периода, оно будет немедленно возвращено. Если после 20 секунд сообщения нет, он возвращается без предоставления сообщения.

Таким образом, ваша функция должна будет снова опросить SQS (возможно, что-то еще сделать за это время).

Answer 2

var processMessages = (function (err, data) { 
    if (data.Messages) { 

     for (i = 0; i < data.Messages.length; i++) { 
      var message = data.Messages[i]; 
      var body = JSON.parse(message.Body); 

      // process message 
      // delete if successful 
     } 
    } 
}); 

while (true) { 
    sqs.receiveMessage({ 
     QueueUrl: sqsQueueUrl, 
     MaxNumberOfMessages: 5, // how many messages to retrieve in a batch 
     VisibilityTimeout: 60, // how long until these messages are available to another consumer 
     WaitTimeSeconds: 15  // how many seconds to wait for messages before continuing 
    }, processMessages); 
}