Include other vhost
This commit is contained in:
parent
b46a7ed684
commit
310b7e91e6
|
@ -74,7 +74,7 @@ describe('Given an amqp10 connection opened, listed and clicked on it', function
|
|||
let sessions = await connectionPage.getSessions()
|
||||
assert.equal(1, sessions.sessions.length)
|
||||
let session = connectionPage.getSessionInfo(sessions.sessions, 0)
|
||||
console.log("session: " + JSON.stringify(session))
|
||||
//console.log("session: " + JSON.stringify(session))
|
||||
assert.equal(0, session.channelNumber)
|
||||
assert.equal(1, session.nextIncomingId)
|
||||
assert.equal(0, session.outgoingUnsettledDeliveries)
|
||||
|
@ -86,7 +86,7 @@ describe('Given an amqp10 connection opened, listed and clicked on it', function
|
|||
assert.equal(1, sessions.outgoing_links.length)
|
||||
|
||||
let incomingLink = connectionPage.getIncomingLinkInfo(sessions.incoming_links, 0)
|
||||
console.log("incomingLink: " + JSON.stringify(incomingLink))
|
||||
//console.log("incomingLink: " + JSON.stringify(incomingLink))
|
||||
assert.equal(1, incomingLink.handle)
|
||||
assert.equal("sender-link", incomingLink.name)
|
||||
assert.equal("examples", incomingLink.targetAddress)
|
||||
|
@ -94,7 +94,7 @@ describe('Given an amqp10 connection opened, listed and clicked on it', function
|
|||
assert.equal("0", incomingLink.unconfirmedMessages)
|
||||
|
||||
let outgoingLink = connectionPage.getOutgoingLinkInfo(sessions.outgoing_links, 0)
|
||||
console.log("outgoingLink: " + JSON.stringify(outgoingLink))
|
||||
//console.log("outgoingLink: " + JSON.stringify(outgoingLink))
|
||||
assert.equal(0, outgoingLink.handle)
|
||||
assert.equal("receiver-link", outgoingLink.name)
|
||||
assert.equal("examples", outgoingLink.sourceAddress)
|
||||
|
|
|
@ -32,13 +32,13 @@ describe('Exchange management', function () {
|
|||
})
|
||||
|
||||
it('display summary of exchanges', async function () {
|
||||
assert.equal("All exchanges (8)", await exchanges.getPagingSectionHeaderText())
|
||||
assert.equal("All exchanges (15)", await exchanges.getPagingSectionHeaderText())
|
||||
})
|
||||
|
||||
it('list all default exchanges', async function () {
|
||||
actual_table = await exchanges.getExchangesTable(3)
|
||||
console.log("a :" + actual_table)
|
||||
expected_table = [
|
||||
let actual_table = await exchanges.getExchangesTable(3)
|
||||
|
||||
let expected_table = [
|
||||
["/", "(AMQP default)", "direct"],
|
||||
["/", "amq.direct", "direct"],
|
||||
["/", "amq.fanout", "fanout"],
|
||||
|
@ -46,8 +46,17 @@ describe('Exchange management', function () {
|
|||
["/", "amq.match", "headers"],
|
||||
["/", "amq.rabbitmq.event", "topic"],
|
||||
["/", "amq.rabbitmq.trace", "topic"],
|
||||
["/", "amq.topic", "topic"]
|
||||
["/", "amq.topic", "topic"],
|
||||
|
||||
["other", "(AMQP default)", "direct"],
|
||||
["other", "amq.direct", "direct"],
|
||||
["other", "amq.fanout", "fanout"],
|
||||
["other", "amq.headers", "headers"],
|
||||
["other", "amq.match", "headers"],
|
||||
["other", "amq.rabbitmq.trace", "topic"],
|
||||
["other", "amq.topic", "topic"]
|
||||
]
|
||||
|
||||
console.log("e :" + actual_table)
|
||||
assert.deepEqual(actual_table, expected_table)
|
||||
})
|
||||
|
|
Loading…
Reference in New Issue