Memory Leak

[cadecairos]

Running the following reduced test case will cause the node process to balloon it's memory usage, especially if it's processing messages. If it's just waiting for new messages, the process still see memory usage increases.

var SqsQueueParallel = require('sqs-queue-parallel');

var queue = new SqsQueueParallel({
  accessKeyId: process.env.AWS_ACCESS_KEY_ID,
  secretAccessKey: process.env.AWS_SECRET_ACCESS_KEY,
  name: process.env.INCOMING_QUEUE_NAME,
  region: process.env.AWS_QUEUE_REGION,
  debug: process.env.DEBUG
});

queue.on("message", function(m) {
  m.deleteMessage(function(err) {
    if ( err ) {
      console.log("Error deleting message:\n%s", err.stack);
    }

    m.next();
  });
});