Function isOnJobCompleteMessage

pkg/dequeuer/batch_handler.go:228–231

(message *sqs.Message)

}

func isOnJobCompleteMessage(message *sqs.Message) bool {
	_, found := message.MessageAttributes["job_complete"]
	return found
}