Can I see the count of unacked messages in RabbitMQ via an AMQP client?
In the RabbitMQ web UI, I can see, for each queue, the number of messages that are ready to be consumed and the number that are being processed but have not yet been acked.
However, I don't see how to get the number of unacked messages via an AMQP client.
For instance, the AMQP.Queue.message_count/2 function in the Elixir client uses the underlying Erlang library to re-declare the queue with passive: true and gets back message_count and consumer_count fields, but the message_count includes only messages that are "ready for delivery (e.g. not pending acknowledgements)".
My goal is to see how big a backlog of messages I currently have. For my purposes, those that are currently being processed are just as much a part of that as those that are ready for processing.
How can I get a count of unacked messages for a given RabbitMQ queue using an AMQP client?
AMQP 0.9-1 does not have that information in the Declare-OK message, nor do I see that in RabbitMQ's AMQP extensions.
If your consumers are similar, you could get use the approximation Total = Ready + ConsumerCount * QoS (QoS being the prefetch count for each consumer), taking into account that if Ready == 0, the approximation is an upper limit (because it's possible for the broker to not have enough messages to satisfy all the consumers).
You have another option, which is using the stats provided by the management plugin through the REST API
- How to add a hover-over tooltip to rhandonstable header cell?
- How to detect the right encoding for read.csv?
- Rcpp Rf_warningcall compiler warnings
- Modify the name of factor variables in lm function(summary function)
- Extreme value analysis and quantile estimation using log Pearson type 3 (Pearson III) distribution - R vs Python
- How to hide NAs when using xlsx::saveWorkbook?
- How do I retrieve a simple numeric value from a named numeric vector in R?
- Adding an image in navbar and adjusting alignment in Rmarkdown
- Matching pair-wise columns from left to right across rows in one dataframe to another dataframe and adding new columns with matching values
- Income to outcome flow chart in Sankey plotly R
- color mapping in geom_conn_bundle not showing correctly
- Print R package startup message AFTER automatic package conflict messages instead of before
- Summing a set of R dataframe rows (column-wise), while retaining the first n columns
- Added variable / partial regression plots for groups in an interaction?
- how to make a topoplot in R with coordinates variable distribution
- List of all functions in base R?
- Plotting multiple plots for different initial conditions in one graph
- Printing repetitively on the same line in R
- Generating UI/Server based on initial selection
- Subset dataframe based on pickerInput
- How to let user pick the data in R-shiny?
- Couldn't show my simple bar charts separately on Shiny R dashboardBody
- How to programmatically filter contents of a second shiny app displayed via iframe
- How to select specific interesting groups for the boxplot in R Shiny app?
- Crosstable and Plot grouping with reactive values
- Is there a way to make multiple Shiny picker inputs where the selections must be disjoint?
- Delay/avoid duplication of shiny server side functions until after credentials
- Predictions only returns value "1"
- How to display a busy indicator in a shiny app?
- Append doesn't work when writing to CSV in R