Method updateStatus

pkg/dequeuer/async_handler.go:143–146

(requestID string, status async.Status)

}

func (h *AsyncMessageHandler) updateStatus(requestID string, status async.Status) error {
	key := async.StatusPath(h.storagePath, requestID, status)
	return h.aws.UploadStringToS3("", h.config.Bucket, key)
}

func (h *AsyncMessageHandler) getPayload(requestID string) (io.ReadCloser, error) {
	key := async.PayloadPath(h.storagePath, requestID)