Open teebu opened 3 years ago
let consumer = client.createQueueReader(sqsEndpoint.url, 1); // batch size: 1 console.log('starting sqs consumers:', consumer.queueName); consumer.start(); consumer.start();
starts the consumer twice, double the events.
The simple solution would be to check if its already listening.
if (!consumer.listening) consumer.start();
starts the consumer twice, double the events.
The simple solution would be to check if its already listening.