chore: release v4.1.1-beta.1

BEagle1984 · Feb 21, 2023 · 5fb0771 · 5fb0771
1 parent dbb968b
commit 5fb0771
Show file tree

Hide file tree

Showing 3 changed files with 17 additions and 14 deletions.
diff --git a/Directory.Build.props b/Directory.Build.props
@@ -1,7 +1,7 @@
 <Project>
   <PropertyGroup Label="Package information">
-    <BaseVersionSuffix></BaseVersionSuffix>
-    <BaseVersion>4.1.0$(BaseVersionSuffix)</BaseVersion>
+    <BaseVersionSuffix>-beta.1</BaseVersionSuffix>
+    <BaseVersion>4.1.1$(BaseVersionSuffix)</BaseVersion>
     <DatabasePackagesRevision>1</DatabasePackagesRevision>
     <DatabasePackagesVersionSuffix>$(BaseVersionSuffix)</DatabasePackagesVersionSuffix>
   </PropertyGroup>

diff --git a/docs/releases.md b/docs/releases.md
@@ -4,6 +4,13 @@ uid: releases
 
 # Releases
 
+## [4.1.1](https://github.com/BEagle1984/silverback/releases/tag/v4.1.1)
+
+### Fixes
+
+* Fix bug in outbox producer writing to the wrong endpoint [[#165](https://github.com/BEagle1984/silverback/issues/165)]
+
+
 ## [4.1.0](https://github.com/BEagle1984/silverback/releases/tag/v4.1.0)
 
 ### What's new

diff --git a/src/Silverback.Integration/Messaging/Outbound/TransactionalOutbox/OutboxProduceStrategy.cs b/src/Silverback.Integration/Messaging/Outbound/TransactionalOutbox/OutboxProduceStrategy.cs
@@ -1,5 +1,6 @@
 // Copyright (c) 2020 Sergio Aquilini
 // This code is licensed under MIT license (see LICENSE file for details)
+
 using System;
 using System.Threading.Tasks;
 using Microsoft.Extensions.DependencyInjection;
@@ -44,18 +45,13 @@ public Task ProduceAsync(IOutboundEnvelope envelope)
                 Check.NotNull(envelope, nameof(envelope));
 
                 _logger.LogWrittenToOutbox(envelope);
-                IProducer localProducer;
-                if (_producer == null || !_producer.Endpoint.Equals(envelope.Endpoint))
-                {
-                    localProducer = _outboundQueueBroker.GetProducer(envelope.Endpoint);
-                    _producer = localProducer;
-                }
-                else
-                {
-                    localProducer = _producer;
-                }
-
-                return localProducer.ProduceAsync(envelope);
+
+                IProducer? producer = _producer;
+
+                if (producer == null || !producer.Endpoint.Equals(envelope.Endpoint))
+                    producer = _producer = _outboundQueueBroker.GetProducer(envelope.Endpoint);
+
+                return producer.ProduceAsync(envelope);
             }
         }
     }