|
|
@ -241,9 +241,13 @@ public class TriggerCallbackThread { |
|
|
|
// load and clear file, retry
|
|
|
|
// load and clear file, retry
|
|
|
|
for (File callbaclLogFile: callbackLogPath.listFiles()) { |
|
|
|
for (File callbaclLogFile: callbackLogPath.listFiles()) { |
|
|
|
byte[] callbackParamList_bytes = FileUtil.readFileContent(callbaclLogFile); |
|
|
|
byte[] callbackParamList_bytes = FileUtil.readFileContent(callbaclLogFile); |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
// avoid empty file
|
|
|
|
if(callbackParamList_bytes == null || callbackParamList_bytes.length < 1){ |
|
|
|
if(callbackParamList_bytes == null || callbackParamList_bytes.length < 1){ |
|
|
|
|
|
|
|
callbaclLogFile.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(); |
|
|
|
callbaclLogFile.delete(); |
|
|
|