A two-node bed: a joined node opens the adopted broker over the overlay #28
@@ -155,6 +155,12 @@ test("a consumer on a joined node opens the adopted broker on the control-node o
|
|||||||
await install("amqp-ping", NODE);
|
await install("amqp-ping", NODE);
|
||||||
await mesh(`push ${NODE}`, 900_000);
|
await mesh(`push ${NODE}`, 900_000);
|
||||||
|
|
||||||
|
// The consumer minted its grant against anchor's broker only when node2 was composed
|
||||||
|
// (a provision secret is a side-effect of composing the CONSUMER). anchor's provisioner
|
||||||
|
// learns of a cross-node consumer only when anchor is composed again, so push it once more to
|
||||||
|
// mint the vhost. Adding a cross-node consumer means pushing the provider node too (issue 055).
|
||||||
|
await mesh(`push anchor`, 600_000);
|
||||||
|
|
||||||
// amqp-ping's container comes up and stays up (a broker it could not reach would crash-loop it).
|
// amqp-ping's container comes up and stays up (a broker it could not reach would crash-loop it).
|
||||||
const psName = async () => (await on(NODE, `docker ps -a --format '{{.Names}}\t{{.Status}}'`)).out;
|
const psName = async () => (await on(NODE, `docker ps -a --format '{{.Names}}\t{{.Status}}'`)).out;
|
||||||
const deadline = Date.now() + 600_000;
|
const deadline = Date.now() + 600_000;
|
||||||
|
|||||||
Reference in New Issue
Block a user