fix table name prefix bug.

Author: yang-xiaodong

src/DotNetCore.CAP.MySql/MySqlFetchedMessage.cs

@@ -6,14 +6,14 @@ namespace DotNetCore.CAP.MySql
 {
     public class MySqlFetchedMessage : IFetchedMessage
     {
-        private readonly string _connectionString = null;
+        private readonly MySqlOptions _options;
 
-        public MySqlFetchedMessage(int messageId, MessageType type, string connectionString)
+        public MySqlFetchedMessage(int messageId, MessageType type, MySqlOptions options)
         {
             MessageId = messageId;
             MessageType = type;
 
-            _connectionString = connectionString;
+            _options = options;
         }
 
         public int MessageId { get; }
@@ -27,9 +27,9 @@ public void RemoveFromQueue()
 
         public void Requeue()
         {
-            using (var connection = new MySqlConnection(_connectionString))
+            using (var connection = new MySqlConnection(_options.ConnectionString))
             {
-                connection.Execute("insert into `cap.queue`(`MessageId`,`MessageType`) values(@MessageId,@MessageType);"
+                connection.Execute($"insert into `{_options.TableNamePrefix}.queue`(`MessageId`,`MessageType`) values(@MessageId,@MessageType);"
                     , new {MessageId, MessageType });
             }
         }

src/DotNetCore.CAP.MySql/MySqlStorageConnection.cs

@@ -150,7 +150,7 @@ private async Task<IFetchedMessage> FetchNextMessageCoreAsync(string sql, object
             if (fetchedMessage == null)
                 return null;
 
-            return new MySqlFetchedMessage(fetchedMessage.MessageId, fetchedMessage.MessageType, Options.ConnectionString);
+            return new MySqlFetchedMessage(fetchedMessage.MessageId, fetchedMessage.MessageType, Options);
         }
 
         public void Dispose()