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