Reading RabbitMQ Message Statistics

rabbitmq_stats.r

queueStatsToDataframe <- function(uri, username, password) {
  uri <- paste(uri, "api/queues", sep="/")
  credentials = paste(username, password, sep=":")
  doc <- getURL(uri, userpwd=credentials, httpauth=1L)
  src <- fromJSON(doc)
  items.df <- data.frame()
  
  if(length(src) > 0) {
    for(i in 1:length(src)) {
      if(length(src[[i]]$messages_details) == 3) {
        record.df <- data.frame(src[[i]]$name, src[[i]]$messages_details, stringsAsFactors=FALSE)
        names(record.df) <- c("Name", "Rate", "Interval", "LastEvent")
        items.df <- rbind(items.df, record.df)
      }
    }
  }
  
  return(items.df)
}