in awsiotjobs/awsiotjobs.go [339:349]
func (client *Client) jobHandler(mqttClient mqtt.Client, msg mqtt.Message) {
job, err := parseJobMessage(msg.Payload())
if err != nil {
fmt.Printf("Not a job - Ignoring, %s\n", err.Error())
return
}
job.client = client
job.ThingName = client.config.ThingName // This is so the specialized jobs can access the property
job.subscribeToUpdates()
go job.client.config.Handler(job)
}