全面大升级
This commit is contained in:
@@ -14,7 +14,7 @@ func main() {
|
||||
rabbitmqURL := os.Getenv("RABBITMQ_URL")
|
||||
if rabbitmqURL == "" {
|
||||
rabbitmqURL = "amqp://guest:guest@localhost:5672/"
|
||||
}
|
||||
}
|
||||
rmq, err := rabbitmq.NewClient(rabbitmqURL)
|
||||
if err != nil {
|
||||
log.Fatalf("RabbitMQ 连接失败: %v", err)
|
||||
|
||||
Reference in New Issue
Block a user