From 56c9629d3f5b55fb734fe850fa749393577835d9 Mon Sep 17 00:00:00 2001 From: Savorboard Date: Tue, 25 Jul 2017 00:37:02 +0800 Subject: [PATCH] maybe have a dirty read --- src/DotNetCore.CAP.MySql/MySqlStorageConnection.cs | 1 + 1 file changed, 1 insertion(+) diff --git a/src/DotNetCore.CAP.MySql/MySqlStorageConnection.cs b/src/DotNetCore.CAP.MySql/MySqlStorageConnection.cs index 7e78976..a2dddfa 100644 --- a/src/DotNetCore.CAP.MySql/MySqlStorageConnection.cs +++ b/src/DotNetCore.CAP.MySql/MySqlStorageConnection.cs @@ -47,6 +47,7 @@ namespace DotNetCore.CAP.MySql //DELETE FROM [{_prefix}].[Queue] LIMIT 1; //COMMIT; + //TODO : here maybe have a dirty read var sql = $@" SELECT `MessageId`,`MessageType` FROM `{_prefix}.queue` LIMIT 1; DELETE FROM `{_prefix}.queue` LIMIT 1;";