Test SAC

Author: MarcialRosales

selenium/test/amqp.js

@@ -66,6 +66,13 @@ module.exports = {
       'sender' : sender
     }
   },
+  openReceiver: (handler, queueName = "my-queue") => {
+      return handler.connection.open_receiver({
+        source: queueName,
+        target: 'receiver-target',
+        name: 'receiver-link'
+      })
+  },
   close: (connection) => {
     if (connection != null) {
       connection.close()

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

@@ -3,7 +3,8 @@ require('chromedriver')
 const assert = require('assert')
 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 { open: openAmqp, once: onceAmqp, on: onAmqp, close: closeAmqp, 
+        openReceiver : openReceiver} = require('../amqp')
 
 const LoginPage = require('../pageobjects/LoginPage')
 const OverviewPage = require('../pageobjects/OverviewPage')
@@ -96,6 +97,31 @@ describe('Given a quorum queue configured with SAC', function () {
       let consumerTable = await queuePage.getConsumersTable()
       console.log("consumer table: " + JSON.stringify(consumerTable))
       assert.equal("single active", consumerTable[0][6])
+      assert.equal("●", consumerTable[0][5])
+    })
+
+    it('it should have two consumers, after adding a second subscriber', async function() {
+      openReceiver(amqp, queueName)
+      await doWhile(async function() {
+        await queuePage.refresh()
+        await queuePage.isLoaded()
+        return queuePage.getConsumerCount()
+      }, function(count) {
+        return count.localeCompare("2") == 0
+      }, 5000)
+      assert.equal("2", await queuePage.getConsumerCount())
+      assert.equal("Consumers (2)", await queuePage.getConsumersSectionTitle())
+      await queuePage.clickOnConsumerSection()
+      let consumerTable = await queuePage.getConsumersTable()
+      console.log("consumer table: " + JSON.stringify(consumerTable))
+      let activeConsumer = consumerTable[1][6].localeCompare("single active") == 0 ?
+        1 : 0
+      let nonActiveConsumer = activeConsumer == 1 ? 0 : 1
+
+      assert.equal("waiting", consumerTable[nonActiveConsumer][6])
+      assert.equal("○", consumerTable[nonActiveConsumer][5])
+      assert.equal("single active", consumerTable[activeConsumer][6])
+      assert.equal("●", consumerTable[activeConsumer][5])
     })
 
     after(function() {