Skip to content

Commit 2b6d14e

Browse files
Fix issues
1 parent 95a2e37 commit 2b6d14e

File tree

2 files changed

+11
-11
lines changed

2 files changed

+11
-11
lines changed

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

Lines changed: 10 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,7 @@
11
const { By, Key, until, Builder } = require('selenium-webdriver')
22
require('chromedriver')
33
const assert = require('assert')
4-
const { buildDriver, goToHome, captureScreensFor, teardown, doWhile, goToQueue,delay } = require('../utils')
4+
const { buildDriver, goToHome, captureScreensFor, teardown, doUntil, goToQueue,delay } = require('../utils')
55
const { createQueue, deleteQueue, getManagementUrl, basicAuthorization } = require('../mgt-api')
66
const { getAmqpUrl : getAmqpUrl } = require('../amqp')
77
const amqplib = require('amqplib');
@@ -84,7 +84,7 @@ describe('Given a quorum queue configured with SAC', function () {
8484
})
8585

8686
it('it should have one consumer as active', async function() {
87-
await doWhile(async function() {
87+
await doUntil(async function() {
8888
await queuePage.refresh()
8989
await queuePage.isLoaded()
9090
return queuePage.getConsumerCount()
@@ -94,7 +94,7 @@ describe('Given a quorum queue configured with SAC', function () {
9494
assert.equal("1", await queuePage.getConsumerCount())
9595
assert.equal("Consumers (1)", await queuePage.getConsumersSectionTitle())
9696
await queuePage.clickOnConsumerSection()
97-
let consumerTable = await doWhile(async function() {
97+
let consumerTable = await doUntil(async function() {
9898
return queuePage.getConsumersTable()
9999
}, function(table) {
100100
return table[0][6].localeCompare("single active") == 0 &&
@@ -113,7 +113,7 @@ describe('Given a quorum queue configured with SAC', function () {
113113

114114
it('the latter consumer should be active and the former waiting', async function() {
115115

116-
await doWhile(async function() {
116+
await doUntil(async function() {
117117
await queuePage.refresh()
118118
await queuePage.isLoaded()
119119
return queuePage.getConsumerCount()
@@ -124,7 +124,7 @@ describe('Given a quorum queue configured with SAC', function () {
124124
assert.equal("2", await queuePage.getConsumerCount())
125125
assert.equal("Consumers (2)", await queuePage.getConsumersSectionTitle())
126126
await queuePage.clickOnConsumerSection()
127-
let consumerTable = await doWhile(async function() {
127+
let consumerTable = await doUntil(async function() {
128128
return queuePage.getConsumersTable()
129129
}, function(table) {
130130
return table.length == 2 && table[0][1] != "" && table[1][1] != ""
@@ -151,7 +151,7 @@ describe('Given a quorum queue configured with SAC', function () {
151151
error("Failed to close amqp091 connection due to " + error);
152152
}
153153
// ensure there are no more consumers
154-
await doWhile(async function() {
154+
await doUntil(async function() {
155155
await queuePage.refresh()
156156
await queuePage.isLoaded()
157157
return queuePage.getConsumerCount()
@@ -178,7 +178,7 @@ describe('Given a quorum queue configured with SAC', function () {
178178
})
179179

180180
it('it should have one consumer as active', async function() {
181-
await doWhile(async function() {
181+
await doUntil(async function() {
182182
await queuePage.refresh()
183183
await queuePage.isLoaded()
184184
return queuePage.getConsumerCount()
@@ -188,7 +188,7 @@ describe('Given a quorum queue configured with SAC', function () {
188188
assert.equal("1", await queuePage.getConsumerCount())
189189
assert.equal("Consumers (1)", await queuePage.getConsumersSectionTitle())
190190
await queuePage.clickOnConsumerSection()
191-
let consumerTable = await doWhile(async function() {
191+
let consumerTable = await doUntil(async function() {
192192
return queuePage.getConsumersTable()
193193
}, function(table) {
194194
return table[0][6].localeCompare("single active") == 0 &&
@@ -207,7 +207,7 @@ describe('Given a quorum queue configured with SAC', function () {
207207

208208
it('the former consumer should still be active and the latter be waiting', async function() {
209209

210-
await doWhile(async function() {
210+
await doUntil(async function() {
211211
await queuePage.refresh()
212212
await queuePage.isLoaded()
213213
return queuePage.getConsumerCount()
@@ -218,7 +218,7 @@ describe('Given a quorum queue configured with SAC', function () {
218218
assert.equal("2", await queuePage.getConsumerCount())
219219
assert.equal("Consumers (2)", await queuePage.getConsumersSectionTitle())
220220
await queuePage.clickOnConsumerSection()
221-
let consumerTable = await doWhile(async function() {
221+
let consumerTable = await doUntil(async function() {
222222
return queuePage.getConsumersTable()
223223
}, function(table) {
224224
return table.length == 2 && table[0][1] != "" && table[1][1] != ""

selenium/test/vhosts/admin-vhosts.js

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -2,7 +2,7 @@ const { By, Key, until, Builder } = require('selenium-webdriver')
22
require('chromedriver')
33
const assert = require('assert')
44
const { buildDriver, goToHome, captureScreensFor, teardown, doUntil, log, delay } = require('../utils')
5-
const { getManagementUrl, createVhost, deleteVhost } = require('../mgt-api')
5+
const { getManagementUrl, basicAuthorization, createVhost, deleteVhost } = require('../mgt-api')
66

77
const LoginPage = require('../pageobjects/LoginPage')
88
const OverviewPage = require('../pageobjects/OverviewPage')

0 commit comments

Comments
 (0)