func()

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