Fix sql reader column index error

src/DotNetCore.CAP.MySql/IDataStorage.MySql.cs

@@ -195,9 +195,9 @@ namespace DotNetCore.CAP.MySql
                 result.Add(new MediumMessage
                 {
                     DbId = reader.GetInt64(0).ToString(),
-                    Origin = StringSerializer.DeSerialize(reader.GetString(3)),
-                    Retries = reader.GetInt32(4),
-                    Added = reader.GetDateTime(5)
+                    Origin = StringSerializer.DeSerialize(reader.GetString(4)),
+                    Retries = reader.GetInt32(5),
+                    Added = reader.GetDateTime(6)
                 });
             }
 

src/DotNetCore.CAP.PostgreSql/IDataStorage.PostgreSql.cs

@@ -203,9 +203,9 @@ namespace DotNetCore.CAP.PostgreSql
                 result.Add(new MediumMessage
                 {
                     DbId = reader.GetInt64(0).ToString(),
-                    Origin = StringSerializer.DeSerialize(reader.GetString(3)),
-                    Retries = reader.GetInt32(4),
-                    Added = reader.GetDateTime(5)
+                    Origin = StringSerializer.DeSerialize(reader.GetString(4)),
+                    Retries = reader.GetInt32(5),
+                    Added = reader.GetDateTime(6)
                 });
             }
 

src/DotNetCore.CAP.SqlServer/IDataStorage.SqlServer.cs

@@ -202,9 +202,9 @@ namespace DotNetCore.CAP.SqlServer
                 result.Add(new MediumMessage
                 {
                     DbId = reader.GetInt64(0).ToString(),
-                    Origin = StringSerializer.DeSerialize(reader.GetString(3)),
-                    Retries = reader.GetInt32(4),
-                    Added = reader.GetDateTime(5)
+                    Origin = StringSerializer.DeSerialize(reader.GetString(4)),
+                    Retries = reader.GetInt32(5),
+                    Added = reader.GetDateTime(6)
                 });
             }