|
@@ -13,7 +13,7 @@ func failOnError(err error, msg string) {
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
func main() {
|
|
func main() {
|
|
|
- conn, err := amqp.Dial("amqp://user:J70e6K7BRrxrU1dO@rabbitmq.rabbitmq.svc.cluster.local:5672/")
|
|
|
|
|
|
|
+ conn, err := amqp.Dial("amqp://toor:aaaAAA111!!!@ubuntu:5672/")
|
|
|
failOnError(err, "Failed to connect to RabbitMQ")
|
|
failOnError(err, "Failed to connect to RabbitMQ")
|
|
|
defer conn.Close()
|
|
defer conn.Close()
|
|
|
|
|
|
|
@@ -43,7 +43,6 @@ func main() {
|
|
|
failOnError(err, "Failed to register a consumer")
|
|
failOnError(err, "Failed to register a consumer")
|
|
|
|
|
|
|
|
log.Println(" [*] Waiting for messages. To exit press CTRL+C")
|
|
log.Println(" [*] Waiting for messages. To exit press CTRL+C")
|
|
|
- forever := make(chan bool)
|
|
|
|
|
|
|
|
|
|
go func() {
|
|
go func() {
|
|
|
for d := range msgs {
|
|
for d := range msgs {
|
|
@@ -51,5 +50,5 @@ func main() {
|
|
|
}
|
|
}
|
|
|
}()
|
|
}()
|
|
|
|
|
|
|
|
- <-forever
|
|
|
|
|
|
|
+ select {}
|
|
|
}
|
|
}
|