Rename the file to conform to the specification

src/DotNetCore.CAP.MySql/CAP.MySqlCapOptionsExtension.cs

@@ -25,8 +25,8 @@ namespace DotNetCore.CAP
             services.AddSingleton<IStorage, MySqlStorage>();
             services.AddSingleton<IStorageConnection, MySqlStorageConnection>();
 
-            services.AddScoped<ICapPublisher, CapPublisher>();
-            services.AddScoped<ICallbackPublisher, CapPublisher>();
+            services.AddScoped<ICapPublisher, MySqlPublisher>();
+            services.AddScoped<ICallbackPublisher, MySqlPublisher>();
 
             services.AddTransient<ICollectProcessor, MySqlCollectProcessor>();
             services.AddTransient<CapTransactionBase, MySqlCapTransaction>();

src/DotNetCore.CAP.MySql/CapPublisher.cs → src/DotNetCore.CAP.MySql/ICapPublisher.MySql.cs

@@ -14,7 +14,7 @@ using MySql.Data.MySqlClient;
 
 namespace DotNetCore.CAP.MySql
 {
-    public class CapPublisher : CapPublisherBase, ICallbackPublisher, IDisposable
+    public class MySqlPublisher : CapPublisherBase, ICallbackPublisher, IDisposable
     {
         private readonly DbContext _dbContext;
         private readonly MySqlOptions _options;
@@ -22,7 +22,7 @@ namespace DotNetCore.CAP.MySql
 
         private MySqlConnection _connection;
 
-        public CapPublisher(IServiceProvider provider, MySqlOptions options) : base(provider)
+        public MySqlPublisher(IServiceProvider provider, MySqlOptions options) : base(provider)
         {
             _options = options;
 
@@ -49,7 +49,7 @@ namespace DotNetCore.CAP.MySql
                 dbTrans = dbContextTrans.GetDbTransaction();
             }
             var conn = dbTrans?.Connection;
-            return conn.ExecuteScalarAsync<int>(PrepareSql(), message, dbTrans);
+            return conn.ExecuteAsync(PrepareSql(), message, dbTrans);
         }
 
         protected override object GetDbTransaction()