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 <[email protected]>1 parent ab4ac4f commit a9f9d11
File tree
5 files changed
+267
-146
lines changed- src/intersect_sdk/_internal/control_plane/brokers
- tests
- fixtures
- unit
5 files changed
+267
-146
lines changed
0 commit comments