func()

in awsiotjobs/awsiotjobs.go [264:278]


func (je *JobExecution) Reject(err JobError) error {
	log.Printf("JOB REJECTED: %v\n", err)
	je.mux.Lock()
	je.StatusDetails = map[string]interface{}{
		"error": err.Error(),
	}
	je.Status = "REJECTED"
	je.mux.Unlock()
	e := je.sendUpdate()
	if e != nil {
		return err
	}
	je.unsubscribeFromUpdates()
	return nil
}