apache / apache/shenyu

[BUG] — E2e: 30s blind sleeps gating async MQ consumption

Open
#6,817 2 comments 0 reactions 1 assignee Claimed by @yykaue View on GitHub
priority: medium type: bug
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.

Get new issues in your inbox

A short digest of beginner-friendly GitHub issues.