The GitHub Actions job "Build" on 
rocketmq-clients.git/fix/rust-push-consumer-filter-expression has failed.
Run started by GitHub user leizhiyuan (triggered by leizhiyuan).

Head commit for run:
897341c8a3672e5ba767709ba308c81db907897e / zhiyuanlei <[email protected]>
[ISSUE #1406] [Rust] Take PushConsumer filter expression from the subscription

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/39412780216

With regards,
GitHub Actions via GitBox

Reply via email to