stopConsuming function will not stop consuming until all the messages are received and passed into the consuming process. machinery/v1/brokers/sqs/sqs.go Line 113 ...