refractor: fixing word spelling error, fixing some variable 2 lower camel case.

3.2.0-release
mingzhong.li 3 months ago
parent 58d0138083
commit 75ed03a795

@ -134,7 +134,7 @@ public class JobRegistryHelper {
// stop registryOrRemoveThreadPool // stop registryOrRemoveThreadPool
registryOrRemoveThreadPool.shutdownNow(); registryOrRemoveThreadPool.shutdownNow();
// stop monitir (interrupt and wait) // stop monitor (interrupt and wait)
registryMonitorThread.interrupt(); registryMonitorThread.interrupt();
try { try {
registryMonitorThread.join(); registryMonitorThread.join();

@ -240,18 +240,18 @@ public class TriggerCallbackThread {
} }
// load and clear file, retry // load and clear file, retry
for (File callbaclLogFile: callbackLogPath.listFiles()) { for (File callbackLogFile: callbackLogPath.listFiles()) {
byte[] callbackParamList_bytes = FileUtil.readFileContent(callbaclLogFile); byte[] callbackParamList_bytes = FileUtil.readFileContent(callbackLogFile);
// avoid empty file // avoid empty file
if(callbackParamList_bytes == null || callbackParamList_bytes.length < 1){ if(callbackParamList_bytes == null || callbackParamList_bytes.length < 1){
callbaclLogFile.delete(); callbackLogFile.delete();
continue; continue;
} }
List<HandleCallbackParam> callbackParamList = (List<HandleCallbackParam>) JdkSerializeTool.deserialize(callbackParamList_bytes, List.class); List<HandleCallbackParam> callbackParamList = (List<HandleCallbackParam>) JdkSerializeTool.deserialize(callbackParamList_bytes, List.class);
callbaclLogFile.delete(); callbackLogFile.delete();
doCallback(callbackParamList); doCallback(callbackParamList);
} }

@ -76,16 +76,16 @@ public class FileUtil {
} }
public static byte[] readFileContent(File file) { public static byte[] readFileContent(File file) {
Long filelength = file.length(); Long fileLength = file.length();
byte[] filecontent = new byte[filelength.intValue()]; byte[] fileContent = new byte[fileLength.intValue()];
FileInputStream in = null; FileInputStream in = null;
try { try {
in = new FileInputStream(file); in = new FileInputStream(file);
in.read(filecontent); in.read(fileContent);
in.close(); in.close();
return filecontent; return fileContent;
} catch (Exception e) { } catch (Exception e) {
logger.error(e.getMessage(), e); logger.error(e.getMessage(), e);
return null; return null;

@ -15,7 +15,7 @@ public class NetUtil {
private static Logger logger = LoggerFactory.getLogger(NetUtil.class); private static Logger logger = LoggerFactory.getLogger(NetUtil.class);
/** /**
* find avaliable port * find available port
* *
* @param defaultPort * @param defaultPort
* @return * @return

Loading…
Cancel
Save