From b735a33ca0bdad9273c0e045bd2ec24e32c48a4d Mon Sep 17 00:00:00 2001
From: Savorboard <yangxiaodong1214@126.com>
Date: Sat, 21 Apr 2018 19:40:55 +0800
Subject: [PATCH] rename file.

---
 ...nalProcessor.Default.cs => ICollectProcessor.MySql.cs} | 8 ++++----
 1 file changed, 4 insertions(+), 4 deletions(-)
 rename src/DotNetCore.CAP.MySql/{IAdditionalProcessor.Default.cs => ICollectProcessor.MySql.cs} (88%)

diff --git a/src/DotNetCore.CAP.MySql/IAdditionalProcessor.Default.cs b/src/DotNetCore.CAP.MySql/ICollectProcessor.MySql.cs
similarity index 88%
rename from src/DotNetCore.CAP.MySql/IAdditionalProcessor.Default.cs
rename to src/DotNetCore.CAP.MySql/ICollectProcessor.MySql.cs
index fd892cb..4cd0a23 100644
--- a/src/DotNetCore.CAP.MySql/IAdditionalProcessor.Default.cs
+++ b/src/DotNetCore.CAP.MySql/ICollectProcessor.MySql.cs
@@ -10,7 +10,7 @@ using MySql.Data.MySqlClient;
 
 namespace DotNetCore.CAP.MySql
 {
-    internal class DefaultAdditionalProcessor : IAdditionalProcessor
+    internal class MySqlCollectProcessor : ICollectProcessor
     {
         private const int MaxBatch = 1000;
         private readonly TimeSpan _delay = TimeSpan.FromSeconds(1);
@@ -18,7 +18,7 @@ namespace DotNetCore.CAP.MySql
         private readonly MySqlOptions _options;
         private readonly TimeSpan _waitingInterval = TimeSpan.FromMinutes(5);
 
-        public DefaultAdditionalProcessor(ILogger<DefaultAdditionalProcessor> logger,
+        public MySqlCollectProcessor(ILogger<MySqlCollectProcessor> logger,
             MySqlOptions mysqlOptions)
         {
             _logger = logger;
@@ -27,8 +27,6 @@ namespace DotNetCore.CAP.MySql
 
         public async Task ProcessAsync(ProcessingContext context)
         {
-            _logger.LogDebug("Collecting expired entities.");
-
             var tables = new[]
             {
                 $"{_options.TableNamePrefix}.published",
@@ -37,6 +35,8 @@ namespace DotNetCore.CAP.MySql
 
             foreach (var table in tables)
             {
+                _logger.LogDebug($"Collecting expired data from table [{table}].");
+               
                 int removedCount;
                 do
                 {