Update main.go
This commit is contained in:
@@ -103,6 +103,7 @@ func main() {
|
|||||||
|
|
||||||
amqpUrl, ok := os.LookupEnv("RABBIT_HOST")
|
amqpUrl, ok := os.LookupEnv("RABBIT_HOST")
|
||||||
if ok {
|
if ok {
|
||||||
|
log.Printf("Connecting to rabbitmq")
|
||||||
conn, err := amqp.DialConfig(amqpUrl, amqp.Config{
|
conn, err := amqp.DialConfig(amqpUrl, amqp.Config{
|
||||||
Properties: amqp.NewConnectionProperties(),
|
Properties: amqp.NewConnectionProperties(),
|
||||||
})
|
})
|
||||||
|
|||||||
Reference in New Issue
Block a user