var queue = new SqsQueueParallel({
name: "queue1",
region:process.env.REGION,
accessKeyId:process.env.ACCESS_KEY_ID,
secretAccessKey:process.env.SECRET_ACCESS_KEY,
maxNumberOfMessages: 10,
concurrency: 10
});
queue.on('message', function (message)
{
//more code
});
name: "queue1",
region:process.env.REGION,
accessKeyId:process.env.ACCESS_KEY_ID,
secretAccessKey:process.env.SECRET_ACCESS_KEY,
maxNumberOfMessages: 10,
concurrency: 10
});
queue.on('message', function (message)
{
//more code
});
No comments:
Post a Comment