[BUG] — E2e: 30s blind sleeps gating async MQ consumption
- Dominant language
- Java
- Stars
- 8.8k
- Forks
- 3.1k
- Avg merge
- 7d 1h
- Merged PRs (30d)
- 85
Description
- severity: Low-Medium; files: `shenyu-e2e/shenyu-e2e-case/shenyu-e2e-case-logging-rocketmq/.../DividePluginCases.java:103` (`Thread.sleep(1000*30)` before starting the MQ consumer) and `:121` (sleep 30s before `assertTrue(isLog.get())`)
- description: Fixed 30s sleeps around `DefaultMQPushConsumer` async delivery. The first sleep can even cause the consumer to miss the message published before `consumer.start()`.
- impact: `DividePluginCases` e2e assertion fails on slow broker.
- suggested_fix: Start the consumer before publishing; poll `isLog` with `Awaitility` and a bounded timeout.
- confidence: High
---
_Identified during the 2026-08-02 deep re-scan; full list in [`docs/scan2-2026-08-02/06-medium-tiers.md`](docs/scan2-2026-08-02/06-medium-tiers.md)._
Contributor guide
No contributing guide indexed for this repository
Assessment
This issue has not been assessed yet.