| | |
|---|
| | | * 站点车辆满架率预警 |
|---|
| | | * @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 ) |
|---|
