The GitHub Actions job "Build" on rocketmq-clients.git/fix/rust-telemetry-session-defects has succeeded. Run started by GitHub user lizhimins (triggered by lizhimins).
Head commit for run: ff007230913c80294dd884e8eb97ef5d1fac0147 / zhaohaihzb <[email protected]> fix(rust): reconnect the requested peer instead of the access endpoint `reconnect_session` rebuilt a missing session from `option.access_url()` while reporting `Ok(true)` for the peer that was asked for. When the two differ (broker endpoint drift), the reconnect retry loop logged "telemetry stream for peer ... re-established" and exited although that peer had no stream at all. Session-map keys always come from `Endpoints::endpoint_url`, so the peer url round-trips back into a valid endpoint and the rebuild can target it directly. The new test took no part in the `MTX` serialization that the other `MockSession::new_context()` tests use, so mockall's process-wide context was swapped under concurrently running tests and the suite failed at random (`MockSession::new: No matching expectation found`). `client_get_session` had the same gap. Both now take the lock. Report URL: https://github.com/apache/rocketmq-clients/actions/runs/39969586560 With regards, GitHub Actions via GitBox
