|
|
@@ -80,17 +80,18 @@ public class AliyunConsumerGroupService {
|
|
|
return;
|
|
|
}
|
|
|
log.info("允许开启订阅");
|
|
|
- // 开启订阅
|
|
|
- Executors.newSingleThreadScheduledExecutor()
|
|
|
- .schedule(()->{
|
|
|
- try {
|
|
|
- client.start(messageListener);
|
|
|
- } catch (Exception e) {
|
|
|
- e.printStackTrace();
|
|
|
- }
|
|
|
- log.info("阿里云物联网订阅成功。。。。。。。。。。。");
|
|
|
- },
|
|
|
- Optional.ofNullable(delayTime).orElse(0L)*2,TimeUnit.SECONDS ) ;
|
|
|
+ try {
|
|
|
+ client.start(messageListener);
|
|
|
+ } catch (Exception e) {
|
|
|
+ e.printStackTrace();
|
|
|
+ }
|
|
|
+ log.info("阿里云物联网订阅成功。。。。。。。。。。。");
|
|
|
+// // 开启订阅
|
|
|
+// Executors.newSingleThreadScheduledExecutor()
|
|
|
+// .schedule(()->{
|
|
|
+//
|
|
|
+// },
|
|
|
+// Optional.ofNullable(delayTime).orElse(0L)*2,TimeUnit.SECONDS ) ;
|
|
|
|
|
|
}
|
|
|
|