[tunnelbroker] Recover AMQP before publishing messages
Needs ReviewPublic
Actions

Authored by bartek on Fri, Oct 4, 3:38 AM.

Details

Reviewers

kamil
will
varun

Summary

Similiar to D13607 (recover when session is closing) and D13606 (consumer is broken).
Before publishing, check channel state and recover if needed. Eventually propagate error if both fail.

Depends on D13609

Test Plan

Tested on staging with the rest of the stack

Diff Detail

Repository

rCOMM Comm

Lint

No Lint Coverage

Unit

No Test Coverage

Event Timeline

bartek created this revision.Fri, Oct 4, 3:38 AM

bartek held this revision as a draft.

Herald added subscribers: tomek, ashoat. · View Herald TranscriptFri, Oct 4, 3:38 AM

Harbormaster completed remote builds in B32066: Diff 44897.Fri, Oct 4, 3:54 AM

bartek published this revision for review.Fri, Oct 4, 4:10 AM

bartek edited the summary of this revision. (Show Details)Fri, Oct 4, 8:21 AM

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

bartek added a parent revision: D13609: [tunnelbroker] Remove legacy AMQP connect function.

bartek removed a parent revision: D13610: [tunnelbroker] Recreate closed channels in pool.

Revision Contents
Changeset List

Path

Size

services/

tunnelbroker/

src/

websockets/

session.rs

35 lines

Diff 44897

View Options

services/tunnelbroker/src/websockets/session.rs

[tunnelbroker] Recover AMQP before publishing messagesNeeds ReviewPublicActions