Issue649 - create a metric for broker side queued message count, and report in sr3 status #818

petersilva · 2023-11-10T22:10:15Z

closes sr3 status display size of queue. #649
had to have the moth/amqp declare a second management channel... this one is synchronous, whereas on the normal data channel, there can be a lot of messages in flight.
now every subscriber has two channels the normal one and the management one.
plugged a call to queue declare in the metricsReport routine, but found it was called more often than I liked.
added a timer to keep it from declaring the queue more than once every 30 seconds.

…, collect metric

petersilva added 5 commits November 10, 2023 14:50

start of #649, create management_channel, declare queue to get q size…

b74d2d1

…, collect metric

#767 add display to sr.py status

4459212

for #767 reduce frequency of calls to queueDeclare

48ba11b

for #767 add passive, to not declare the queue, when query for metrics

9cb97b4

working on #767, touchup to make code a little more obvious

5f2ef81

petersilva assigned reidsunderland, MagikEh, iMacadan, tysonkaufmann and andreleblanc11 Nov 10, 2023

petersilva added 2 commits November 10, 2023 17:35

cumulating queued messages and retries

7d6e9c1

for #767 add cumulation

aab91fc

petersilva merged commit 0627284 into development Nov 14, 2023
4 checks passed

reidsunderland mentioned this pull request Nov 16, 2023

Review amqp.py to consider publish_confirms, consumers, etc... #457

Open

petersilva deleted the issue649 branch November 20, 2023 23:54

Provide feedback