From a806df20dd3abb877f55884adfd63367de96b814 Mon Sep 17 00:00:00 2001 From: wangshaoming Date: Mon, 8 Apr 2019 12:24:10 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E5=A4=8D=E9=87=8D=E8=AF=95=E6=96=87?= =?UTF-8?q?=E4=BB=B6=E6=B2=A1=E6=9C=89=E6=B8=85=E6=A5=9A=E7=9A=84=E9=97=AE?= =?UTF-8?q?=E9=A2=98?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- src/DotXxlJob.Core/Queue/CallbackTaskQueue.cs | 2 +- src/DotXxlJob.Core/Queue/RetryCallbackTaskQueue.cs | 11 ++++++++++- 2 files changed, 11 insertions(+), 2 deletions(-) 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; }