Skip to content

Latest commit

 

History

History
99 lines (59 loc) · 3.23 KB

CHANGELOG.md

File metadata and controls

99 lines (59 loc) · 3.23 KB
Raw

1.7.9

  • Add method to get the number of consumers

  • 1.7.8

  • Fix potential connection leak

1.7.7

  • Expose GetMessageCountInQueueAsync API

1.7.6

  • Test about sourcelink

1.7.5

  • Test about sourcelink

1.7.4

1.7.3

  • Add option to allow to override mandatory flag when publishing a message
  • Add option to configure connection heartbeat (disabled by default)

1.7.2

  • Add new consumer option to choose consumer prefetch count

1.7.1

  • Rework Consumer pipeline. Since deserialization can fail, it has been move after the Log Exception Pipe and after the Message Ack Pipe, so it does not "lock" the consumer when deserializer fail.

1.7

  • Follow RabbitMQ recommendations about connections
    • 1 connection for publishing
    • 1 connection for consuming
  • When using .WithSerializer() define default deserializer with it if none has been defined

1.6

  • StartListeningQueueAsync delegate will now take CancellationToken as 3rd argument.
  • Add new methods on IActiveConsumer to choose how to cancel the current processing
    • CancelAfterCurrentTaskCompletedAsync() will prevent further processing after the current processing message has been completed.
    • CancelAsync() will cancel the token given to the StartListeningQueueAsync and cancel further processing.

1.5.1

  • default deserializer is now optional if another deserializer has been specified

1.5

  • Add a new pipe to log processing exception in consumer pipe: LogExceptionConsumerPipe
  • Add a way to configure DeliveryMode on message RabbitMqServiceOptionsBuilder.WithDeliveryMode()

1.4

  • Declare delegates for serializer/deserializer functions
  • Rework Serialization logic to allow specify which serializer to use when enqueueing a message

1.3.2

  • Declare delegate to improve readability and usage of messageProcessor in StartListeningQueueAsync

1.3.1

  • Add a new overload WithCustomPipe on ConsumerOptionsBuilder to be able to define pipeline inline. (Like .Use() for ASP.NET Core middlewares)

1.3

  • Allow specifying an array of TimeSpan for client retry logic.

1.2

  • Allow specifying ExchangeName/RoutingKey when publishing a message as an alternative to QueueName.
  • Add new CreateQueueOptionBuilder to simplify how to create a queue with custom arguments.
  • Allow specifying contextItems when enqueueing a message. This databag is available through the IPipeContext.Items in pipes.
  • Add a new option to configure message expiration
  • Add new Consumer Pipe DelayedRetryMessageAcknowledgementPipe to retry failed message with a delay between retry

1.1

  • Create pipelines only when they are needed. So it does not throw because Serializer is missing when creating a client to listen to a queue, for example.
  • Rework how to consume messages from a queue. It now uses pipeline pattern. See documentation for more details.
  • Add new Consumer Pipe FastRetryMessageAcknowledgementPipe that can handle retry when a message encounters an error during processing.

1.0

  • Initial Release
  • Create/Delete/Purge Queue
  • Listen to a queue (no error handling yet)
  • Publish message
  • Retry logic for all action if the server is down