diff --git a/src/DotXxlJob.Core/Queue/CallbackTaskQueue.cs b/src/DotXxlJob.Core/Queue/CallbackTaskQueue.cs index 93129dd..fb16d7c 100644 --- a/src/DotXxlJob.Core/Queue/CallbackTaskQueue.cs +++ b/src/DotXxlJob.Core/Queue/CallbackTaskQueue.cs @@ -89,7 +89,7 @@ namespace DotXxlJob.Core.Queue ReturnT result; try { - result = await this._adminClient.Callback(list); + result = await _adminClient.Callback(list); } catch (Exception ex){ this._logger.LogError(ex,"trigger callback error:{error}",ex.Message); diff --git a/src/DotXxlJob.Core/Queue/RetryCallbackTaskQueue.cs b/src/DotXxlJob.Core/Queue/RetryCallbackTaskQueue.cs index 40a68bc..e7a2ec4 100644 --- a/src/DotXxlJob.Core/Queue/RetryCallbackTaskQueue.cs +++ b/src/DotXxlJob.Core/Queue/RetryCallbackTaskQueue.cs @@ -76,6 +76,15 @@ namespace DotXxlJob.Core.Queue } } + try + { + File.Delete(_backupFile); //ɾ³ý±¸·ÝÎļþ + } + + catch (Exception ex) + { + this._logger.LogError(ex, "delete backup file error:{error}", ex.Message); + } if (list.Any()) { foreach (var item in list) @@ -88,7 +97,7 @@ namespace DotXxlJob.Core.Queue public void Push(List list) { - if (!list.Any()) + if (list?.Count == 0) { return; }