You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by bl...@apache.org on 2021/07/05 14:07:56 UTC
[pulsar-dotpulsar] branch master updated: Fix producer message
metadata bug and make ready for release 1.1.1
This is an automated email from the ASF dual-hosted git repository.
blankensteiner pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar-dotpulsar.git
The following commit(s) were added to refs/heads/master by this push:
new caca029 Fix producer message metadata bug and make ready for release 1.1.1
caca029 is described below
commit caca029ee421098f6f4a32a44f47a9c6fbe0fb5a
Author: Daniel Blankensteiner <db...@vmail.dk>
AuthorDate: Mon Jul 5 16:07:47 2021 +0200
Fix producer message metadata bug and make ready for release 1.1.1
---
CHANGELOG.md | 6 ++++++
src/DotPulsar/DotPulsar.csproj | 2 +-
src/DotPulsar/Internal/Producer.cs | 10 ++++++++--
3 files changed, 15 insertions(+), 3 deletions(-)
diff --git a/CHANGELOG.md b/CHANGELOG.md
index 972cae5..4ef009c 100644
--- a/CHANGELOG.md
+++ b/CHANGELOG.md
@@ -4,6 +4,12 @@ All notable changes to this project will be documented in this file.
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.1] - 2021-07-05
+
+### Fixed
+
+- The producer ignored message metadata provided by the end-user
+
## [1.1.0] - 2021-06-29
### Added
diff --git a/src/DotPulsar/DotPulsar.csproj b/src/DotPulsar/DotPulsar.csproj
index 1dadb0d..a12e88e 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.0</Version>
+ <Version>1.1.1</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 5951a1d..067ac12 100644
--- a/src/DotPulsar/Internal/Producer.cs
+++ b/src/DotPulsar/Internal/Producer.cs
@@ -221,10 +221,16 @@ namespace DotPulsar.Internal
}
public async ValueTask<MessageId> Send(TMessage message, CancellationToken cancellationToken)
- => await _producers[await ChoosePartitions(null, cancellationToken).ConfigureAwait(false)].Send(message, cancellationToken).ConfigureAwait(false);
+ {
+ var partition = await ChoosePartitions(null, cancellationToken).ConfigureAwait(false);
+ return await _producers[partition].Send(message, cancellationToken).ConfigureAwait(false);
+ }
public async ValueTask<MessageId> Send(DotPulsar.MessageMetadata metadata, TMessage message, CancellationToken cancellationToken)
- => await _producers[await ChoosePartitions(metadata, cancellationToken).ConfigureAwait(false)].Send(message, cancellationToken).ConfigureAwait(false);
+ {
+ var partition = await ChoosePartitions(null, cancellationToken).ConfigureAwait(false);
+ return await _producers[partition].Send(metadata, message, cancellationToken).ConfigureAwait(false);
+ }
private void ThrowIfDisposed()
{