func()

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)
}