Function NewBatchMessageHandler

pkg/dequeuer/batch_handler.go:58–73

(config BatchMessageHandlerConfig, awsClient *awslib.Client, statsdClient statsd.ClientInterface, log *zap.SugaredLogger)

}

func NewBatchMessageHandler(config BatchMessageHandlerConfig, awsClient *awslib.Client, statsdClient statsd.ClientInterface, log *zap.SugaredLogger) *BatchMessageHandler {
	tags := []string{
		"api_name:" + config.APIName,
		"job_id:" + config.JobID,
	}

	return &BatchMessageHandler{
		config:                  config,
		jobCompleteMessageDelay: _jobCompleteMessageDelay,
		tags:                    tags,
		aws:                     awsClient,
		metrics:                 statsdClient,
		log:                     log,
		httpClient:              &http.Client{},
	}
}

func (h *BatchMessageHandler) Handle(message *sqs.Message) error {
	if isOnJobCompleteMessage(message) {