فهرست منبع

remove setupmqtt in keepalive

Max Ma 1 سال پیش
والد
کامیت
da35e971f9
1فایلهای تغییر یافته به همراه0 افزوده شده و 3 حذف شده
  1. 0 3
      mq/mq.go

+ 0 - 3
mq/mq.go

@@ -131,9 +131,6 @@ func Keepalive(ctx context.Context) {
 		case <-ctx.Done():
 			return
 		case <-time.After(time.Second * KEEPALIVE_TIMEOUT):
-			if mqclient == nil || !mqclient.IsConnectionOpen() {
-				SetupMQTT(false)
-			}
 			sendPeers()
 		}
 	}