fix: make ConsumerStatusInfo thread-safe

BEagle1984 · Aug 8, 2023 · b95e1a2 · b95e1a2
1 parent 781a9c6
commit b95e1a2
Show file tree

Hide file tree

Showing 2 changed files with 10 additions and 7 deletions.
diff --git a/Directory.Build.props b/Directory.Build.props
@@ -1,6 +1,6 @@
 <Project>
   <PropertyGroup Label="Package information">
-    <BaseVersionSuffix>-beta.4</BaseVersionSuffix>
+    <BaseVersionSuffix>-beta.5</BaseVersionSuffix>
     <BaseVersion>4.4.0$(BaseVersionSuffix)</BaseVersion>
     <DatabasePackagesRevision>1</DatabasePackagesRevision>
     <DatabasePackagesVersionSuffix>$(BaseVersionSuffix)</DatabasePackagesVersionSuffix>

diff --git a/src/Silverback.Integration/Messaging/Broker/ConsumerStatusInfo.cs b/src/Silverback.Integration/Messaging/Broker/ConsumerStatusInfo.cs
@@ -34,12 +34,15 @@ public void SetConnected(bool allowStepBack = false)
 
         public void RecordConsumedMessage(IBrokerMessageIdentifier? brokerMessageIdentifier)
         {
-            if (Status is ConsumerStatus.Connected or ConsumerStatus.Ready)
-                ChangeStatus(ConsumerStatus.Consuming);
-
-            ConsumedMessagesCount++;
-            LatestConsumedMessageTimestamp = DateTime.Now;
-            LatestConsumedMessageIdentifier = brokerMessageIdentifier;
+            lock (_history)
+            {
+                if (Status is ConsumerStatus.Connected or ConsumerStatus.Ready)
+                    ChangeStatus(ConsumerStatus.Consuming);
+
+                ConsumedMessagesCount++;
+                LatestConsumedMessageTimestamp = DateTime.Now;
+                LatestConsumedMessageIdentifier = brokerMessageIdentifier;
+            }
         }
 
         private void ChangeStatus(ConsumerStatus status)