Commit a9f9d11
committed
stop AMQP message consumer from blocking the heartbeat
the solution is to utilize a separate thread for each consumer tag and to combine this with basic_qos; this guarantees that we only have one thread per AMQP consumer
Signed-off-by: Lance-Drane <Lance-Drane@users.noreply.github.com>1 parent ab4ac4f commit a9f9d11
5 files changed
Lines changed: 267 additions & 146 deletions
File tree
- src/intersect_sdk/_internal/control_plane/brokers
- tests
- fixtures
- unit
0 commit comments