The GitHub Actions job "Build" on rocketmq-clients.git/fix/rust-push-consumer-listener-panic has failed. Run started by GitHub user leizhiyuan (triggered by leizhiyuan).
Head commit for run: adc73871f9b71f25f114436b2b2587c1c0a8e925 / leizhiyuann <[email protected]> [ISSUE #1410] [Rust] Treat a panic in the PushConsumer listener as consume failure The message listener was called directly by the consumer workers, so a panic unwound through the worker task and stopped it for good, and the message being consumed was neither acked nor nacked. Align with the Java client (ConsumeTask#call catches any Throwable raised by the listener and marks the consumption as FAILURE): invoke the listener through catch_unwind in both the standard and the FIFO worker, log the panic and continue with ConsumeResult::FAILURE, so the message goes through the normal redelivery / local retry / DLQ path. Also take the static-mock lock in client::tests::client_get_session; it set MockSession::new expectations without it and could race with test_get_session_for_lite_consumer. Report URL: https://github.com/apache/rocketmq-clients/actions/runs/39422493960 With regards, GitHub Actions via GitBox
