Pārlūkot izejas kodu

add comment.

master
Savorboard pirms 7 gadiem
vecāks
revīzija
85b7319c56
1 mainītis faili ar 3 papildinājumiem un 1 dzēšanām
  1. +3
    -1
      src/DotNetCore.CAP.MySql/MySqlStorageConnection.cs

+ 3
- 1
src/DotNetCore.CAP.MySql/MySqlStorageConnection.cs Parādīt failu

@@ -45,7 +45,9 @@ namespace DotNetCore.CAP.MySql
var sql = $@"
SELECT `MessageId`,`MessageType` FROM `{_prefix}.queue` LIMIT 1 FOR UPDATE;
DELETE FROM `{_prefix}.queue` LIMIT 1;";
// var sql = $@"

// The following `sql` can improve performance, but repeated consumption occurs in multiple instances
//var sql = $@"
//SELECT @MId:=`MessageId` as MessageId, @MType:=`MessageType` as MessageType FROM `{_prefix}.queue` LIMIT 1;
//DELETE FROM `{_prefix}.queue` where `MessageId` = @MId AND `MessageType`=@MType;";



Notiek ielāde…
Atcelt
Saglabāt