Compare commits
1 Commits
| Author | SHA256 | Date | |
|---|---|---|---|
| af066c520c |
@@ -92,10 +92,13 @@ func ConnectToExchangeForPublish(host, username, password string) {
|
|||||||
auth = username + ":" + password + "@"
|
auth = username + ":" + password + "@"
|
||||||
}
|
}
|
||||||
|
|
||||||
connection, err := rabbitmq.DialTLS("amqps://"+auth+host, &tls.Config{
|
connection, err := rabbitmq.DialConfig("amqps://"+auth+host, rabbitmq.Config{
|
||||||
ServerName: host,
|
Dial: rabbitmq.DefaultDial(10 * time.Second),
|
||||||
|
TLSClientConfig: &tls.Config{
|
||||||
|
ServerName: host,
|
||||||
|
},
|
||||||
})
|
})
|
||||||
failOnError(err, "Cannot connect to rabbit.opensuse.org")
|
failOnError(err, "Cannot connect to "+host)
|
||||||
defer connection.Close()
|
defer connection.Close()
|
||||||
|
|
||||||
ch, err := connection.Channel()
|
ch, err := connection.Channel()
|
||||||
|
|||||||
Reference in New Issue
Block a user