Fix metadata not being passed to the message router and make ready for release 1.1.2
diff --git a/CHANGELOG.md b/CHANGELOG.md
index 4ef009c..e90c41d 100644
--- a/CHANGELOG.md
+++ b/CHANGELOG.md
@@ -4,11 +4,17 @@
The format is based on [Keep a Changelog](https://keepachangelog.com/en/1.0.0/), and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0.html).
+## [1.1.2] - 2021-07-05
+
+### Fixed
+
+- The partitioned producer didn't pass metadata to the message router
+
## [1.1.1] - 2021-07-05
### Fixed
-- The producer ignored message metadata provided by the end-user
+- The producer ignored message metadata provided by the user
## [1.1.0] - 2021-06-29
diff --git a/src/DotPulsar/DotPulsar.csproj b/src/DotPulsar/DotPulsar.csproj
index a12e88e..9dca04d 100644
--- a/src/DotPulsar/DotPulsar.csproj
+++ b/src/DotPulsar/DotPulsar.csproj
@@ -2,7 +2,7 @@
<PropertyGroup>
<TargetFrameworks>netstandard2.0;netstandard2.1;netcoreapp3.1;net5.0</TargetFrameworks>
- <Version>1.1.1</Version>
+ <Version>1.1.2</Version>
<AssemblyVersion>$(Version)</AssemblyVersion>
<FileVersion>$(Version)</FileVersion>
<Authors>ApachePulsar,DanskeCommodities,dblank</Authors>
diff --git a/src/DotPulsar/Internal/Producer.cs b/src/DotPulsar/Internal/Producer.cs
index 067ac12..a84d7c9 100644
--- a/src/DotPulsar/Internal/Producer.cs
+++ b/src/DotPulsar/Internal/Producer.cs
@@ -228,7 +228,7 @@
public async ValueTask<MessageId> Send(DotPulsar.MessageMetadata metadata, TMessage message, CancellationToken cancellationToken)
{
- var partition = await ChoosePartitions(null, cancellationToken).ConfigureAwait(false);
+ var partition = await ChoosePartitions(metadata, cancellationToken).ConfigureAwait(false);
return await _producers[partition].Send(metadata, message, cancellationToken).ConfigureAwait(false);
}
