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 2020/12/12 16:15:28 UTC

[pulsar-dotpulsar] branch master updated: Updating changelog

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 1ec2307  Updating changelog
1ec2307 is described below

commit 1ec230793ae6897f8a2750fe12be5072f116fe1c
Author: Daniel Blankensteiner <db...@vmail.dk>
AuthorDate: Sat Dec 12 17:15:15 2020 +0100

    Updating changelog
---
 CHANGELOG.md                                                       | 7 +++++++
 .../{NotAllowedErrorException.cs => NotAllowedException.cs}        | 6 +++---
 src/DotPulsar/Internal/Extensions/CommandExtensions.cs             | 2 +-
 3 files changed, 11 insertions(+), 4 deletions(-)

diff --git a/CHANGELOG.md b/CHANGELOG.md
index 9345915..0a558bf 100644
--- a/CHANGELOG.md
+++ b/CHANGELOG.md
@@ -9,6 +9,13 @@ The format is based on [Keep a Changelog](https://keepachangelog.com/en/1.0.0/),
 ### Added
 
 - Added performance improvements when receiving data
+- Added the IHandleStateChanged\<TStateChanged\> interface for easier state monitoring
+- Added StateChangedHandler methods on ConsumerBuilder, ReaderBuilder and ProducerBuilder for easier state monitoring
+- Added StateChangedHandler property on ConsumerOptions, ReaderOptions, and ProducerOptions for easier state monitoring
+- Added four new DotPulsarExceptions: InvalidTransactionStatusException, NotAllowedException, TransactionConflictException and TransactionCoordinatorNotFoundException
+- Added properties on Message to read EventTime and PublishTime as DateTime
+- Added methods on the IMessageBuilder to set EventTime and DeliverAt using DateTime
+- Added properties on MessageMetadata to set EventTime and DeliverAtTime using DateTime
 
 ### Changed
 
diff --git a/src/DotPulsar/Exceptions/NotAllowedErrorException.cs b/src/DotPulsar/Exceptions/NotAllowedException.cs
similarity index 70%
rename from src/DotPulsar/Exceptions/NotAllowedErrorException.cs
rename to src/DotPulsar/Exceptions/NotAllowedException.cs
index d92e2aa..bce6316 100644
--- a/src/DotPulsar/Exceptions/NotAllowedErrorException.cs
+++ b/src/DotPulsar/Exceptions/NotAllowedException.cs
@@ -16,10 +16,10 @@ namespace DotPulsar.Exceptions
 {
     using System;
 
-    public sealed class NotAllowedErrorException : DotPulsarException
+    public sealed class NotAllowedException : DotPulsarException
     {
-        public NotAllowedErrorException(string message) : base(message) { }
+        public NotAllowedException(string message) : base(message) { }
 
-        public NotAllowedErrorException(string message, Exception innerException) : base(message, innerException) { }
+        public NotAllowedException(string message, Exception innerException) : base(message, innerException) { }
     }
 }
diff --git a/src/DotPulsar/Internal/Extensions/CommandExtensions.cs b/src/DotPulsar/Internal/Extensions/CommandExtensions.cs
index 6df4e0f..0365895 100644
--- a/src/DotPulsar/Internal/Extensions/CommandExtensions.cs
+++ b/src/DotPulsar/Internal/Extensions/CommandExtensions.cs
@@ -56,7 +56,7 @@ namespace DotPulsar.Internal.Extensions
                 ServerError.InvalidTopicName => new InvalidTopicNameException(message),
                 ServerError.InvalidTxnStatus => new InvalidTransactionStatusException(message),
                 ServerError.MetadataError => new MetadataException(message),
-                ServerError.NotAllowedError => new NotAllowedErrorException(message),
+                ServerError.NotAllowedError => new NotAllowedException(message),
                 ServerError.PersistenceError => new PersistenceException(message),
                 ServerError.ProducerBlockedQuotaExceededError => new ProducerBlockedQuotaExceededException($"{message}. Error code: {error}"),
                 ServerError.ProducerBlockedQuotaExceededException => new ProducerBlockedQuotaExceededException($"{message}. Error code: {error}"),