test

upload/mq.go

@@ -31,11 +31,14 @@ 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)
@@ -43,6 +46,7 @@ func (r *RabbitMQ) mqConnect() error {
 		}
 		r.channel = c
 		beeLogger.Log.Success("RabbitMQ Server is running...")
+	}
 
 	return nil
 }
@@ -64,7 +68,9 @@ func (r *RabbitMQ) mqClose() {
 
 func (r *RabbitMQ) Send(req map[string]interface{}) error {
 	//defer r.mqClose()
-
+	if err := r.mqConnect(); err != nil {
+		return err
+	}
 	bytes, err := json.Marshal(req)
 	if err != nil {
 		return err