func()

in awsiotjobs/awsiotjobs.go [388:397]


func (client *Client) init(c Config) {
	client.config = c
	opts := mqtt.NewClientOptions()
	opts.AddBroker(fmt.Sprintf("ssl://%s:%d", c.Endpoint, c.Port))
	opts.SetClientID(c.ClientID).SetTLSConfig(NewTLSConfig(c.CaCertPath, c.CertificatePath, c.PrivateKeyPath))
	opts.SetDefaultPublishHandler(defaultHandler)
	opts.SetAutoReconnect(true)
	opts.SetMaxReconnectInterval(10 * time.Minute)
	client.Iot = mqtt.NewClient(opts)
}