zhaohai666 opened a new pull request, #1388:
URL: https://github.com/apache/rocketmq-clients/pull/1388
## P4 fix(nodejs): correct message-group routing and consumption lifecycle
guards
- `PublishingLoadBalancer`: interpret SipHash-2-4 as **signed** int64 and
apply
`floorMod` for message-group routing (the previous unsigned modulo routed
"negative"
hashes to different queues).
- `PushConsumer`: bound the cached-message drain wait by
`requestTimeout + longPollingTimeout` so shutdown cannot hang forever.
- `SimpleConsumer`: guard `receive()` / `ack()` /
`changeInvisibleDuration()` with
`isRunning()`.
- `LiteSubscriptionManager`: sync lite subscriptions to **all** route
endpoints;
expose `LitePushConsumerImpl#getTotalRouteEndpoints()`.
**Tests:** `nodejs/test/producer/PublishingLoadBalancer.test.ts` (2 cases,
offline, all pass)
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
