Changed

• Updated the Microsoft.Extensions.ObjectPool dependency from version 8.0.6 to 8.0.7

Fixed

• Under some circumstances 'AuthenticateAsClientAsync' will hang after a network issue. Setting the receive and send timeouts on the TCP client should fix this

Changed

• Updated the Microsoft.Extensions.ObjectPool dependency from version 8.0.6 to 8.0.7

Fixed

• Under some circumstances 'AuthenticateAsClientAsync' will hang after a network issue. Setting the receive and send timeouts on the TCP client should fix this

Added

• The consumer's subscription type is now part of the IConsumer interface

Fixed

• Fixed race condition in Producer between Send(...) and DisposeAsync() dispose causing an unintended DivideByZeroException.
  It now throws a ProducerClosedException.
• The Process extension method will hang when called with EnsureOrderedAcknowledgment set to true, a shared subscription and MaxDegreeOfParallelism above 1.
  It now throws a ProcessingException when EnsureOrderedAcknowledgment is set to true and with a shared subscription type.

Added

• The consumer's subscription type is now part of the IConsumer interface

Fixed

• Fixed race condition in Producer between Send(...) and DisposeAsync() dispose causing an unintended DivideByZeroException.
  It now throws a ProducerClosedException.
• The Process extension method will hang when called with EnsureOrderedAcknowledgment set to true, a shared subscription and MaxDegreeOfParallelism above 1.
  It now throws a ProcessingException when EnsureOrderedAcknowledgment is set to true and with a shared subscription type.

Added

Producer properties can be added when creating a producer

Changed

Updated the Microsoft.Extensions.ObjectPool dependency from version 8.0.4 to 8.0.6

Added

Producer properties can be added when creating a producer

Changed

Updated the Microsoft.Extensions.ObjectPool dependency from version 8.0.4 to 8.0.6

Fixed

RoundRobinPartitionRouter and SinglePartitionRouter could return a negative number. They have been changed to ensure they always return a non-negative integer.

Fixed

RoundRobinPartitionRouter and SinglePartitionRouter could return a negative number. They have been changed to ensure they always return a non-negative integer.

Added

IReceive now has a 'TryReceive' extension method allowing for non-blocking retrieval of buffered messages

Changed

Updated the Microsoft.Extensions.ObjectPool dependency from version 8.0.1 to 8.0.3

Fixed

Disposing a newly created consumer or reader could result in an exception being thrown
Concurrent 'Receive' invocations on a partitioned topic could result in an exception being thrown

Added

IReceive now has a 'TryReceive' extension method allowing for non-blocking retrieval of buffered messages

Changed

Updated the Microsoft.Extensions.ObjectPool dependency from version 8.0.1 to 8.0.3

Fixed

Disposing a newly created consumer or reader could result in an exception being thrown
Concurrent 'Receive' invocations on a partitioned topic could result in an exception being thrown

Fixed

• When sending a message that is too large the broker will close the tcp connection, causing the producer to disconnect, reconnect, and retry in an endless loop.
  Now a TooLargeMessageException is thrown (will be given to the exception handler) and the producer's state is changed to 'Faulted'
• A race condition could cause Send(..) operations of the producer to hang after a reconnect

Fixed

• When sending a message that is too large the broker will close the tcp connection, causing the producer to disconnect, reconnect, and retry in an endless loop.
  Now a TooLargeMessageException is thrown (will be given to the exception handler) and the producer's state is changed to 'Faulted'
• A race condition could cause Send(..) operations of the producer to hang after a reconnect

Fixed

• Fixed a bug where disposing a disconnected consumer, reader or producer would cause a hang

Full Changelog: https://github.com/apache/pulsar-dotpulsar/compare/3.1.0...3.1.1

Fixed

• Fixed a bug where disposing a disconnected consumer, reader or producer would cause a hang

What's Changed

• Although README.md doesn't mention it, DotPulsar actually supports partitioned topics for the consumer. by @entvex in https://github.com/apache/pulsar-dotpulsar/pull/180
• Remove the unused artifacts from the ci-unit. by @entvex in https://github.com/apache/pulsar-dotpulsar/pull/185
• Stop duplicate code comments for code review. by @entvex in https://github.com/apache/pulsar-dotpulsar/pull/181
• Release process and GitHub Action to release a NuGet packages, based on tags. by @entvex in https://github.com/apache/pulsar-dotpulsar/pull/184
• Streamlined the release process for DotPulsar. by @entvex in https://github.com/apache/pulsar-dotpulsar/pull/186
• CodeQL by @entvex in https://github.com/apache/pulsar-dotpulsar/pull/187
• Small fix for publish-to-nuget.yml by @entvex in https://github.com/apache/pulsar-dotpulsar/pull/188
• Updated publish-to-nuget.yml to use dotnet 8 by @entvex in https://github.com/apache/pulsar-dotpulsar/pull/189
• Removed AssemblyVersion and FileVersion from csproj by @entvex in https://github.com/apache/pulsar-dotpulsar/pull/190
• publish-to-nuget.yml ->Fix path by @entvex in https://github.com/apache/pulsar-dotpulsar/pull/191

Full Changelog: https://github.com/apache/pulsar-dotpulsar/compare/3.0.2...3.1.0

Added

• .NET 8 added as a target framework

Changed

• Updated the Microsoft.Extensions.ObjectPool dependency from version 7.0.11 to 8.0.0
• Updated the System.IO.Pipelines dependency from version 7.0.0 to 8.0.0

Fixed

• A race condition could cause a hang when trying to dispose a client
• A race condition could cause a producer, consumer, or reader to never exit the disconnected state

Removed

• The 'GetLastMessageId' method on IReader and IConsumer has been removed. Use 'GetLastMessageIds' instead
• The 'AuthenticateUsingToken' method on IPulsarClientBuilder has been removed. Use Authentication(AuthenticationFactory.Token(...)) instead

Added

• .NET 8 added as a target framework

Changed

• Updated the Microsoft.Extensions.ObjectPool dependency from version 7.0.11 to 8.0.0
• Updated the System.IO.Pipelines dependency from version 7.0.0 to 8.0.0

Fixed

• A race condition could cause a hang when trying to dispose a client
• A race condition could cause a producer, consumer, or reader to never exit the disconnected state

Removed

• The 'GetLastMessageId' method on IReader and IConsumer has been removed. Use 'GetLastMessageIds' instead
• The 'AuthenticateUsingToken' method on IPulsarClientBuilder has been removed. Use Authentication(AuthenticationFactory.Token(...)) instead