Merge pull request #1934 from tomzhang170/tomzhang170-patch-1
Update TriggerCallbackThread.java
This commit is contained in:
commit
3fe5120060
|
@ -241,6 +241,9 @@ 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);
|
||||||
|
if(callbackParamList_bytes == null || callbackParamList_bytes.length < 1){
|
||||||
|
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();
|
||||||
|
|
Loading…
Reference in New Issue