From b0ef25abf150d88b2a4888e4bf0d2ae858ad3751 Mon Sep 17 00:00:00 2001 From: liurunyu <lry9898@163.com> Date: 星期六, 07 六月 2025 16:13:27 +0800 Subject: [PATCH] 增加山东设备的MQTT协议的发布消息、订阅消息值对象 --- pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/schedulerTask/SchedulerTaskSupport.java | 12 +++++++++++- 1 files changed, 11 insertions(+), 1 deletions(-) diff --git a/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/schedulerTask/SchedulerTaskSupport.java b/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/schedulerTask/SchedulerTaskSupport.java index 0fc205e..7b135ad 100644 --- a/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/schedulerTask/SchedulerTaskSupport.java +++ b/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/schedulerTask/SchedulerTaskSupport.java @@ -19,6 +19,17 @@ SchedulerTaskSupport.threadPoolPriority = threadPoolPriority; } } + + /** + * 鍒犻櫎宸ヤ綔浠诲姟 + * @param jobName + * @param jobGroupName + * @throws SchedulerException + */ + public static void deleteJob(String jobName, String jobGroupName) throws SchedulerException{ + Scheduler sched = SchedulerTaskFactory.getSingleScheduler() ; + sched.deleteJob(new JobKey(jobName, jobGroupName)); + } /** * 娣诲姞姣廥绉掗挓閲嶅宸ヤ綔涓�娆$殑宸ヤ綔浠诲姟锛� @@ -61,7 +72,6 @@ .withIntervalInSeconds(intervalInSeconds) .withRepeatCount(repeatCount)) .build(); - sched.scheduleJob(job, trigger); sched.start(); -- Gitblit v1.8.0