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:
06f8cd0e62ced12de065e09844dd83cf9f99ed4c / leizhiyuann <[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/39412966153

With regards,
GitHub Actions via GitBox

Reply via email to