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:
d8637d26bc7dc6a02eb9714b775050b11e4abdfa / Lei Zhiyuan <[email protected]>
[ISSUE #1410] [Rust] Treat a panic in the PushConsumer listener as consume 
failure (#1411)

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

With regards,
GitHub Actions via GitBox

Reply via email to