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 <[email protected]>
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}"),
