The GitHub Actions job "Build" on rocketmq-clients.git/master has failed.
Run started by GitHub user lizhimins (triggered by lizhimins).

Head commit for run:
3a47e1de95deea3909b6ff64fd26cc0b24d0e611 / Lei Zhiyuan <[email protected]>
[ISSUE #1406] [Rust] Take PushConsumer filter expression from the subscription 
(#1407)

The filter expression used by ReceiveMessage was looked up by the assigned
message queue's topic name. Servers may return a decorated name such as
"<instance>%<topic>", so the lookup failed, no ReceiveMessage was sent and
the worker spun on a 1 ms ticker without backoff.

Align with the Java client:
- pass the subscription's FilterExpression from scanAssignments to
  MessageQueueActor (PushConsumerImpl#syncProcessQueue / ProcessQueueImpl)
- back off 20 ms on TooManyRequests and 1 s on other receive failures
  (ProcessQueueImpl#onReceiveMessageException)

Report URL: https://github.com/apache/rocketmq-clients/actions/runs/39881510443

With regards,
GitHub Actions via GitBox

Reply via email to