Skip to content

EventHorizon.RocketMQ.Remoting 0.3.0

Choose a tag to compare

View all tags
@eventhorizon-cli eventhorizon-cli released this 04 Aug 14:56
remoting-v0.3.0
9e7ab94
This commit was created on GitHub.com and signed with GitHub’s verified signature.
GPG key ID: B5690EEEBB952194
Verified
Learn about vigilant mode.

Highlights

  • Consolidates classic PULL and POP receive engines behind IRemotingPushConsumer. Queue assignment and receive mode are now modeled separately: client assignment uses PULL, while Broker assignment follows each server-returned PULL or POP assignment.
  • Adds RemotingPushQueueAssignmentMode and the QueueAssignmentMode option. Client remains the default; applications keep the same Push handler when Broker assignment selects POP.
  • Reorganizes the Consumer implementation around explicit coordination, assignment, receive, processing, settlement, offset, and lifecycle ownership.
  • Fixes Broker-assigned retry coordination, current-Broker resolution for POP settlement, orderly queue unlock during shutdown, LitePull shutdown positions, and Push receiver shutdown ownership.
  • Expands live coverage for PULL/POP workflows, multiple Brokers, multiple NameServers, failover, cross-process coordination, retries, blocked queues, and persistence.
  • Documents the fixed Remoting POP invisibility deadline: unlike gRPC Push, classic Remoting Push does not automatically renew an active POP receipt.

Breaking changes

  • Removes the standalone public IRemotingPopConsumer API. Configure Broker queue assignment on IRemotingPushConsumer; the Broker selects PULL or POP for each assignment.
  • Removes the low-level public IRemotingPullConsumer API. Use IRemotingLitePullConsumer for application-driven polling or IRemotingPushConsumer for callback-driven consumption.
  • Replaces the previous Push assignment option with RemotingPushQueueAssignmentMode and RemotingPushConsumerOptions.QueueAssignmentMode.
  • Moves LitePull types to the EventHorizon.RocketMQ.Remoting.Consumer.LitePull namespace.

NuGet: https://www.nuget.org/packages/EventHorizon.RocketMQ.Remoting/0.3.0

Assets 2
Loading