|  |  |  | 
|---|
|  |  |  | * 站点车辆满架率预警 | 
|---|
|  |  |  | * @throws Exception | 
|---|
|  |  |  | */ | 
|---|
|  |  |  | //    @Scheduled(fixedDelay = 1000L *20L ) | 
|---|
|  |  |  | //    public void reSubMqtt() throws Exception { | 
|---|
|  |  |  | //        log.info("=====================检查是否需要重新订阅===========start============"); | 
|---|
|  |  |  | //        MqttClientInit.isSubClientValid(); | 
|---|
|  |  |  | //        log.info("=====================检查是否需要重新订阅===========end============"); | 
|---|
|  |  |  | //    } | 
|---|
|  |  |  | @Scheduled(fixedDelay = 1000L *20L ) | 
|---|
|  |  |  | public void reSubMqtt() throws Exception { | 
|---|
|  |  |  | log.info("=====================检查是否需要重新订阅===========start============"); | 
|---|
|  |  |  | MqttClientInit.isSubClientValid(); | 
|---|
|  |  |  | log.info("=====================检查是否需要重新订阅===========end============"); | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  |  | 
|---|
|  |  |  | @Scheduled(fixedDelay = 1000L * 100L ) | 
|---|