From 75ed03a795bf4313e8667fcc591a2611fe72942c Mon Sep 17 00:00:00 2001 From: "mingzhong.li" Date: Thu, 26 Jun 2025 13:17:27 +0800 Subject: [PATCH] refractor: fixing word spelling error, fixing some variable 2 lower camel case. --- .../com/xxl/job/admin/core/thread/JobRegistryHelper.java | 2 +- .../com/xxl/job/core/thread/TriggerCallbackThread.java | 8 ++++---- .../src/main/java/com/xxl/job/core/util/FileUtil.java | 8 ++++---- .../src/main/java/com/xxl/job/core/util/NetUtil.java | 2 +- 4 files changed, 10 insertions(+), 10 deletions(-) diff --git a/xxl-job-admin/src/main/java/com/xxl/job/admin/core/thread/JobRegistryHelper.java b/xxl-job-admin/src/main/java/com/xxl/job/admin/core/thread/JobRegistryHelper.java index 9e961c57..b302664c 100644 --- a/xxl-job-admin/src/main/java/com/xxl/job/admin/core/thread/JobRegistryHelper.java +++ b/xxl-job-admin/src/main/java/com/xxl/job/admin/core/thread/JobRegistryHelper.java @@ -134,7 +134,7 @@ public class JobRegistryHelper { // stop registryOrRemoveThreadPool registryOrRemoveThreadPool.shutdownNow(); - // stop monitir (interrupt and wait) + // stop monitor (interrupt and wait) registryMonitorThread.interrupt(); try { registryMonitorThread.join(); diff --git a/xxl-job-core/src/main/java/com/xxl/job/core/thread/TriggerCallbackThread.java b/xxl-job-core/src/main/java/com/xxl/job/core/thread/TriggerCallbackThread.java index 1d272466..11041171 100644 --- a/xxl-job-core/src/main/java/com/xxl/job/core/thread/TriggerCallbackThread.java +++ b/xxl-job-core/src/main/java/com/xxl/job/core/thread/TriggerCallbackThread.java @@ -240,18 +240,18 @@ public class TriggerCallbackThread { } // load and clear file, retry - for (File callbaclLogFile: callbackLogPath.listFiles()) { - byte[] callbackParamList_bytes = FileUtil.readFileContent(callbaclLogFile); + for (File callbackLogFile: callbackLogPath.listFiles()) { + byte[] callbackParamList_bytes = FileUtil.readFileContent(callbackLogFile); // avoid empty file if(callbackParamList_bytes == null || callbackParamList_bytes.length < 1){ - callbaclLogFile.delete(); + callbackLogFile.delete(); continue; } List callbackParamList = (List) JdkSerializeTool.deserialize(callbackParamList_bytes, List.class); - callbaclLogFile.delete(); + callbackLogFile.delete(); doCallback(callbackParamList); } diff --git a/xxl-job-core/src/main/java/com/xxl/job/core/util/FileUtil.java b/xxl-job-core/src/main/java/com/xxl/job/core/util/FileUtil.java index d44ef4b2..8a9f6a40 100644 --- a/xxl-job-core/src/main/java/com/xxl/job/core/util/FileUtil.java +++ b/xxl-job-core/src/main/java/com/xxl/job/core/util/FileUtil.java @@ -76,16 +76,16 @@ public class FileUtil { } public static byte[] readFileContent(File file) { - Long filelength = file.length(); - byte[] filecontent = new byte[filelength.intValue()]; + Long fileLength = file.length(); + byte[] fileContent = new byte[fileLength.intValue()]; FileInputStream in = null; try { in = new FileInputStream(file); - in.read(filecontent); + in.read(fileContent); in.close(); - return filecontent; + return fileContent; } catch (Exception e) { logger.error(e.getMessage(), e); return null; diff --git a/xxl-job-core/src/main/java/com/xxl/job/core/util/NetUtil.java b/xxl-job-core/src/main/java/com/xxl/job/core/util/NetUtil.java index f7b96505..323667bc 100644 --- a/xxl-job-core/src/main/java/com/xxl/job/core/util/NetUtil.java +++ b/xxl-job-core/src/main/java/com/xxl/job/core/util/NetUtil.java @@ -15,7 +15,7 @@ public class NetUtil { private static Logger logger = LoggerFactory.getLogger(NetUtil.class); /** - * find avaliable port + * find available port * * @param defaultPort * @return