juju 9c31b0ca95 fix: Fixed the bug where the bus was closed and consumers had unfinished messages. (#1179) ...

* fix: Fixed the bug where the bus was closed and consumers had unfinished messages.

* fix: remove unnecessary blank line in Close method

* fix: refactor message bus and channel handling for improved performance and reliability

* fix: improve message handling and bus closure logic for better reliability

* fix: reduce sleep duration in agent loop for improved responsiveness

* fix the test case

2026-03-18 00:12:12 +08:00

..

bus_test.go

fix: Fixed the bug where the bus was closed and consumers had unfinished messages. (#1179)

2026-03-18 00:12:12 +08:00

bus.go

fix: Fixed the bug where the bus was closed and consumers had unfinished messages. (#1179)

2026-03-18 00:12:12 +08:00

types.go

Removed the old heavy logic

2026-03-08 18:22:15 +01:00