in awsiotjobs/awsiotjobs.go [407:416]
func (client *Client) ConnectAndSubscribe() {
fmt.Println("ConnectAndSubscribe - Connecting")
if token := client.Iot.Connect(); token.Wait() && token.Error() != nil {
panic(token.Error())
}
client.subscribe()
fmt.Println("ConnectAndSubscribe - Checking for jobs")
client.Iot.Publish(fmt.Sprintf(jobBaseTopic, client.config.ThingName, "start-next"), 1, false, "")
log.Println("ConnectAndSubscribe - Done")
}