Test SAC with one consumer

pending to test with 2 consumers

Author: MarcialRosales

deps/rabbitmq_management/priv/www/js/tmpl/consumers.ejs

@@ -1,5 +1,5 @@
 <% if (consumers.length > 0) { %>
-    <table class="list">
+    <table class="list" id="consumers">
       <thead>
         <tr>
 <% if (mode == 'queue') { %>

selenium/test/mgt-api.js

@@ -192,7 +192,7 @@ module.exports = {
       throw new Error(req.responseText)
     }
   },
-  createQueue: (url, authorization, vhost, name, queueType = "quorum") => {    
+  createQueue: (url, authorization, vhost, name, arguments = {}) => {    
     log("Create queue " + JSON.stringify(name) 
       + " in vhost " + vhost + " on " + url)
     const req = new XMLHttpRequest()
@@ -203,9 +203,7 @@ module.exports = {
     req.setRequestHeader('Content-Type', 'application/json')
     let payload = {
       "durable": true,
-      "arguments":{
-        "x-queue-type" : queueType
-      }
+      "arguments": arguments
     }
     req.send(JSON.stringify(payload))
     if (req.status == 200 || req.status == 204 || req.status == 201) {

selenium/test/pageobjects/BasePage.js

@@ -37,7 +37,9 @@ module.exports = class BasePage {
   async goTo(path) {
     return driver.get(d.baseUrl + path)  
   }
-
+  async refresh() {
+    return this.driver.navigate().refresh()
+  }
   async isLoaded () {
     return this.waitForDisplayed(MENU_TABS)
   }

selenium/test/pageobjects/QueuePage.js

@@ -12,14 +12,13 @@ const STATS_CONSUMER_COUNT = By.css('table#details-queue-stats-table td#consumer
 
 const CONSUMERS_SECTION = By.css('div#queue-consumers-section')
 const CONSUMERS_SECTION_TITLE = By.css('div#queue-consumers-section h2')
+const CONSUMERS_TABLE = By.css('div#queue-consumers-section table.list#consumers')
 
 module.exports = class QueuePage extends BasePage {
   async isLoaded() {
     return this.waitForDisplayed(QUEUE_NAME)
   }
-  async refresh() {
-    return this.driver.navigate().refresh()
-  }
+
   async getName() {
     return this.getText(QUEUE_NAME)
   }
@@ -35,6 +34,9 @@ module.exports = class QueuePage extends BasePage {
   async clickOnConsumerSection() {
     return this.click(CONSUMERS_SECTION)
   }
+  async getConsumersTable() {
+    return this.getTable(CONSUMERS_TABLE)
+  }
   async ensureDeleteQueueSectionIsVisible() {    
     await this.click(DELETE_SECTION)
     return this.driver.findElement(DELETE_SECTION).isDisplayed()

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

@@ -18,7 +18,7 @@ var untilConnectionEstablished = new Promise((resolve, reject) => {
   })
 })
 
-describe('Given a quorum queue', function () {
+describe('Given a quorum queue configured with SAC', function () {
   let login
   let queuesAndStreams
   let queuePage
@@ -46,7 +46,10 @@ describe('Given a quorum queue', function () {
     queueName = "test_" + Math.floor(Math.random() * 1000)
 
     createQueue(getManagementUrl(), basicAuthorization("management", "guest"), 
-       "/", queueName, "quorum")
+       "/", queueName, {
+        "x-queue-type": "quorum", 
+        "x-single-active-consumer": true
+      })
 
     await goToQueue(driver, "/", queueName)
     await queuePage.isLoaded()
@@ -57,10 +60,14 @@ describe('Given a quorum queue', function () {
   it('it must display its queue-type and durability', async function () {    
     let table = await queuePage.getFeatures()
     assert.equal(table[0].name, "arguments:")
-    let expectedArguments = [{"name":"x-queue-type:","value":"quorum"}]
+    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].name, "x-single-active-consumer:")
     assert.equal(table[1].value, "true")        
+    assert.equal(table[2].name, "durable:")
+    assert.equal(table[2].value, "true")        
   })
 
   it('it should not have any consumers', async function() {
@@ -85,6 +92,10 @@ describe('Given a quorum queue', function () {
       }, 5000)
       assert.equal("1", await queuePage.getConsumerCount())
       assert.equal("Consumers (1)", await queuePage.getConsumersSectionTitle())
+      await queuePage.clickOnConsumerSection()
+      let consumerTable = await queuePage.getConsumersTable()
+      console.log("consumer table: " + JSON.stringify(consumerTable))
+      assert.equal("single active", consumerTable[0][6])
     })
 
     after(function() {