Optimize amqp sdk

sunmi-OS · Mar 22, 2024 · 86dfa86 · 86dfa86
1 parent faac75e
commit 86dfa86
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/rabbitmq/rabbitmq.go b/rabbitmq/rabbitmq.go
@@ -24,13 +24,13 @@ func connRbbitmq() error {
 		scheme = "amqps"
 	}
 
-	amqpcoinf := amqp.Config{
+	amqpConfig := amqp.Config{
 		Vhost:     vhost,
 		Heartbeat: 10 * time.Second,
 		Locale:    "en_US",
 	}
 
-	conn, err := amqp.DialConfig(fmt.Sprintf("%s://%s:%s@%s:%s/", scheme, user, password, host, port), amqpcoinf)
+	conn, err := amqp.DialConfig(fmt.Sprintf("%s://%s:%s@%s:%s/", scheme, user, password, host, port), amqpConfig)
 	if err != nil {
 		return err
 	}