func()

in awsiotjobs/awsiotjobs.go [301:309]


func (je *JobExecution) updateHandler(client mqtt.Client, msg mqtt.Message) {
	payload := updatePayload{}
	json.Unmarshal(msg.Payload(), &payload)
	log.Printf("%v\n", payload)
	je.mux.Lock()
	je.VersionNumber = payload.ExecutionState.VersionNumber
	je.StatusDetails = payload.ExecutionState.StatusDetails
	je.mux.Unlock()
}