Test consumer count after consumer connected

Author: MarcialRosales

selenium/test/amqp.js

@@ -40,20 +40,22 @@ function getConnectionOptions() {
 }
 module.exports = {  
 
-  open: () => {
+  open: (queueName = "my-queue") => {
     let promise = new Promise((resolve, reject) => {
       container.on('connection_open', function(context) {
         resolve()
       })
     })
+    console.log("Opening amqp connection using " + JSON.stringify(connectionOptions))
+    
     let connection = container.connect(connectionOptions)
     let receiver = connection.open_receiver({
-      source: 'my-queue',
+      source: queueName,
       target: 'receiver-target',
       name: 'receiver-link'
     })
     let sender = connection.open_sender({
-      target: 'my-queue',
+      target: queueName,
       source: 'sender-source',
       name: 'sender-link'
     })

selenium/test/pageobjects/QueuePage.js

@@ -10,10 +10,16 @@ const DELETE_BUTTON = By.css('div#main div#delete input[type=submit]')
 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')
 
+const CONSUMERS_SECTION = By.css('div#queue-consumers-section')
+const CONSUMERS_SECTION_TITLE = By.css('div#queue-consumers-section h2')
+
 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)
   }
@@ -23,6 +29,12 @@ module.exports = class QueuePage extends BasePage {
   async getFeatures() {
     return this.getTableMini(FEATURES_TABLE)
   }
+  async getConsumersSectionTitle() {
+    return this.getText(CONSUMERS_SECTION_TITLE)
+  }
+  async clickOnConsumerSection() {
+    return this.click(CONSUMERS_SECTION)
+  }
   async ensureDeleteQueueSectionIsVisible() {    
     await this.click(DELETE_SECTION)
     return this.driver.findElement(DELETE_SECTION).isDisplayed()

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

@@ -1,15 +1,23 @@
 const { By, Key, until, Builder } = require('selenium-webdriver')
 require('chromedriver')
 const assert = require('assert')
-const { buildDriver, goToHome, captureScreensFor, teardown, log, goToQueue } = require('../utils')
+const { buildDriver, goToHome, captureScreensFor, teardown, doWhile, goToQueue } = require('../utils')
 const { createQueue, deleteQueue, getManagementUrl, basicAuthorization } = require('../mgt-api')
+const { open: openAmqp, once: onceAmqp, on: onAmqp, close: closeAmqp } = require('../amqp')
 
 const LoginPage = require('../pageobjects/LoginPage')
 const OverviewPage = require('../pageobjects/OverviewPage')
 const QueuesAndStreamsPage = require('../pageobjects/QueuesAndStreamsPage')
 const QueuePage = require('../pageobjects/QueuePage')
 const StreamPage = require('../pageobjects/StreamPage')
 
+var untilConnectionEstablished = new Promise((resolve, reject) => {
+  onAmqp('connection_open', function(context) {
+    console.log("Amqp connection opened")
+    resolve()
+  })
+})
+
 describe('Given a quorum queue', function () {
   let login
   let queuesAndStreams
@@ -18,7 +26,7 @@ describe('Given a quorum queue', function () {
   let stream
   let overview
   let captureScreen
-
+  
   before(async function () {
     driver = buildDriver()
     await goToHome(driver)
@@ -40,20 +48,54 @@ describe('Given a quorum queue', function () {
     createQueue(getManagementUrl(), basicAuthorization("management", "guest"), 
        "/", queueName, "quorum")
 
-  })
-
-  it('add quorum queue and view it', async function () {    
     await goToQueue(driver, "/", queueName)
     await queuePage.isLoaded()
     assert.equal(queueName, await queuePage.getName())
+    
+  })
+
+  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"}]
     assert.equal(JSON.stringify(table[0].value), JSON.stringify(expectedArguments))
     assert.equal(table[1].name, "durable:")
-    assert.equal(table[1].value, "true")    
+    assert.equal(table[1].value, "true")        
+  })
 
+  it('it should not have any consumers', async function() {
     assert.equal("0", await queuePage.getConsumerCount())
+    assert.equal("Consumers (0)", await queuePage.getConsumersSectionTitle())
+  })
+
+  describe("given there is a consumer attached to the queue", function () {
+    let amqp 
+    before(async function() {
+      amqp = openAmqp(queueName)
+      await untilConnectionEstablished          
+    })
+
+    it('it should have one consumer', async function() {
+      await doWhile(async function() {
+        await queuePage.refresh()
+        await queuePage.isLoaded()
+        return queuePage.getConsumerCount()
+      }, function(count) {
+        return count.localeCompare("0") == 1
+      }, 5000)
+      assert.equal("1", await queuePage.getConsumerCount())
+      assert.equal("Consumers (1)", await queuePage.getConsumersSectionTitle())
+    })
+
+    after(function() {
+      try {
+        if (amqp != null) {
+          closeAmqp(amqp.connection)
+        }
+      } catch (error) {
+        error("Failed to close amqp10 connection due to " + error);      
+      }  
+    })
   })
 
   after(async function () {