Validate consumer count on quorum queue

Author: MarcialRosales

deps/rabbitmq_management/priv/www/js/tmpl/quorum-queue-stats.ejs

@@ -1,23 +1,24 @@
-   <table class="facts facts-l">
+   <table class="facts facts-l" id="details-queue-stats-table">
+      <tbody>
       <tr>
         <th>State</th>
         <td><%= fmt_object_state(queue) %></td>
       </tr>
       <% if(queue.consumers) { %>
       <tr>
         <th>Consumers</th>
-        <td><%= fmt_string(queue.consumers) %></td>
+        <td id="consumers"><%= fmt_string(queue.consumers) %></td>
       </tr>
       <% } else if(queue.hasOwnProperty('consumer_details')) { %>
       <tr>
         <th>Consumers</th>
-        <td><%= fmt_string(queue.consumer_details.length) %></td>
+        <td id="consumers"><%= fmt_string(queue.consumer_details.length) %></td>
       </tr>
       <% } %>
       <% if(queue.hasOwnProperty('publishers')) { %>
       <tr>
         <th>Publishers</th>
-        <td><%= fmt_string(queue.publishers) %></td>
+        <td id="publishers"><%= fmt_string(queue.publishers) %></td>
       </tr>
       <% } %>
       <tr>
@@ -30,6 +31,7 @@
         <td><%= fmt_string(queue.delivery_limit) %></td>
       </tr>
       <% } %>
+    </tbody>
     </table>
 
     <table class="facts">

selenium/test/pageobjects/BasePage.js

@@ -158,11 +158,9 @@ module.exports = class BasePage {
     let tbody = await table.findElement(By.css('tbody'))
     let rows = await tbody.findElements(By.xpath("./child::*"))
 
-    console.log("getTableMiniUsingTableElement found " + rows.length + " rows")
     let table_model = []
     for (let row of rows) {
       let columnName = await row.findElement(By.css('th')).getText()
-      console.log("getTableMiniUsingTableElement parsing column Name " + columnName )
 
       let columnValue = await row.findElement(By.css('td'))
       let columnContent = await columnValue.findElement(By.xpath("./child::*"))

selenium/test/pageobjects/QueuePage.js

@@ -7,7 +7,8 @@ const QUEUE_NAME = By.css('div#main h1 b')
 
 const DELETE_SECTION = By.css('div#main div#delete')
 const DELETE_BUTTON = By.css('div#main div#delete input[type=submit]')
-const FEATURES = By.css('table#details-queue-table td#details-queue-features table.mini')
+const FEATURES_TABLE = By.css('table#details-queue-table td#details-queue-features table.mini')
+const STATS_CONSUMER_COUNT = By.css('table#details-queue-stats-table td#consumers')
 
 module.exports = class QueuePage extends BasePage {
   async isLoaded() {
@@ -16,8 +17,11 @@ module.exports = class QueuePage extends BasePage {
   async getName() {
     return this.getText(QUEUE_NAME)
   }
+  async getConsumerCount() {
+    return this.getText(STATS_CONSUMER_COUNT)
+  }
   async getFeatures() {
-    return this.getTableMini(FEATURES)
+    return this.getTableMini(FEATURES_TABLE)
   }
   async ensureDeleteQueueSectionIsVisible() {    
     await this.click(DELETE_SECTION)

selenium/test/queuesAndStreams/view-qq-consumers.js

@@ -47,10 +47,16 @@ describe('Given a quorum queue', function () {
     await queuePage.isLoaded()
     assert.equal(queueName, await queuePage.getName())
     let table = await queuePage.getFeatures()
-    console.log("Queue features: " + JSON.stringify(table))
+    assert.equal(table[0].name, "arguments:")
+    let expectedArguments = [{"name":"x-queue-type:","value":"quorum"}]
+    assert.equal(JSON.stringify(table[0].value), JSON.stringify(expectedArguments))
+    assert.equal(table[1].name, "durable:")
+    assert.equal(table[1].value, "true")    
+
+    assert.equal("0", await queuePage.getConsumerCount())
   })
 
-  after(async function () {    
+  after(async function () {
     await teardown(driver, this, captureScreen)
     deleteQueue(getManagementUrl(), basicAuthorization("management", "guest"), 
       "/", queueName)