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 faa61dc Reader faulted issue (#156)
faa61dc is described below
commit faa61dc266fa8daee2fde47e230f9f6384f5b7f9
Author: Kristian Andersen <[email protected]>
AuthorDate: Fri May 26 12:54:53 2023 +0200
Reader faulted issue (#156)
* Convert reader and consumer to process actions sequentially
Queue actions and process one by one
* Refactor to reduce duplication
Move process queue to Abscract Process class
* Remove uninteded duplicate call
---
CHANGELOG.md | 4 ++++
src/DotPulsar/Internal/ReaderProcess.cs | 1 -
2 files changed, 4 insertions(+), 1 deletion(-)
diff --git a/CHANGELOG.md b/CHANGELOG.md
index f701407..d84fc4c 100644
--- a/CHANGELOG.md
+++ b/CHANGELOG.md
@@ -8,6 +8,10 @@ The format is based on [Keep a
Changelog](https://keepachangelog.com/en/1.0.0/)
- Support for consuming partitioned topics
+### Fixed
+
+- Fixed issue preventing reader to correctly go into `Faulted` state.
+
## [2.12.0] - ?
### Added
diff --git a/src/DotPulsar/Internal/ReaderProcess.cs
b/src/DotPulsar/Internal/ReaderProcess.cs
index e421c5f..98b6407 100644
--- a/src/DotPulsar/Internal/ReaderProcess.cs
+++ b/src/DotPulsar/Internal/ReaderProcess.cs
@@ -47,7 +47,6 @@ public sealed class ReaderProcess : Process
if (ExecutorState == ExecutorState.Faulted)
{
- _stateManager.SetState(ReaderState.Faulted);
var formerState = _stateManager.SetState(ReaderState.Faulted);
if (formerState != ReaderState.Faulted)
ActionQueue.Enqueue(async _ => await
_reader.ChannelFaulted(Exception!) );
