test

upload/mq.go

@@ -30,14 +30,13 @@ func (r *RabbitMQ) mqConnect() error {
 		"test-rmq.offcncloud.com/",
 		5672)
 
-	if r.connection == nil {
 	if r.connection, err = amqp.DialConfig(RabbitUrl, amqp.Config{Vhost: "v.ofc.office"}); err != nil {
 		beeLogger.Log.Errorf("RabbitMQ Server Connect Fail: %s", err)
 		return err
 	}
-	}
 
-	if r.connection == nil {
+
+
 	c, err := r.connection.Channel()
 	if err != nil {
 		beeLogger.Log.Errorf("Channel connet fail: %s", err)
@@ -45,7 +44,7 @@ func (r *RabbitMQ) mqConnect() error {
 	}
 	r.channel = c
 	beeLogger.Log.Success("RabbitMQ Server is running...")
-	}
+
 
 	return nil
 }