fix
This commit is contained in:
parent
1308e265a6
commit
a29aefbe97
1 changed files with 1 additions and 1 deletions
|
|
@ -50,7 +50,7 @@ func main() {
|
|||
// === RabbitMQ setup ===
|
||||
rmqURL := os.Getenv("RABBITMQ_URL")
|
||||
if rmqURL == "" {
|
||||
rmqURL = "amqp://guest:guest@10.1.0.65:5672/"
|
||||
rmqURL = "amqp://guest:guest@rabbitmq:5672/"
|
||||
}
|
||||
|
||||
rmqConn, err := amqp091.Dial(rmqURL)
|
||||
|
|
|
|||
Loading…
Add table
Add a link
Reference in a new issue