[tunnelbroker] Create thread-safe wrapper over AMQP connection
ClosedPublic
Actions

Authored by bartek on Oct 3 2024, 1:35 PM.

Details

Reviewers

kamil
varun
will

Commits

rCOMM0018440a6003: [tunnelbroker] Create thread-safe wrapper over AMQP connection

Summary

Thread-safe wrapper over lapin connection, along with channel pool.
Now implemented initial connection creation, this functionality is extended in the next diffs

Depends on D13600

Test Plan

Tested together with the rest of the stack. Test plan in D13595

Diff Detail

Repository

rCOMM Comm

Lint

No Lint Coverage

Unit

No Test Coverage

Event Timeline

bartek created this revision.Oct 3 2024, 1:35 PM

bartek held this revision as a draft.

Herald added subscribers: tomek, ashoat. · View Herald TranscriptOct 3 2024, 1:35 PM

bartek added a child revision: D13602: [tunnelbroker] Implement AMQP Channel hash-modulo-N pool.Oct 3 2024, 1:35 PM

bartek edited the summary of this revision. (Show Details)Oct 3 2024, 1:50 PM

bartek edited the test plan for this revision. (Show Details)

Harbormaster completed remote builds in B32052: Diff 44881.Oct 3 2024, 1:52 PM

Rebase

Harbormaster completed remote builds in B32061: Diff 44891.Oct 4 2024, 3:39 AM

bartek published this revision for review.Oct 4 2024, 3:44 AM

bartek added inline comments.

services/tunnelbroker/src/amqp.rs
87 ↗	(On Diff #44891)	This is addressed in D13608
services/tunnelbroker/src/constants.rs
10 ↗	(On Diff #44891)	RabbitMQ docs say typical application should have "a single digit" of channels