it("unregisters event listeners when amqp connection is closed", async () => {
    const original = { test: "data" };

    let count = 0;

    const incrementCount = () => {
      count++;
    };

    app2.service("todo").on("created", incrementCount);
    onCreated(app2);

    app2.sync.connection.reconnect();

    // Wait for the connection to be back
    await new Promise((resolve) => {
      app2.sync.connection.once("connect", resolve);
    });

    await app1.service("todo").create(original);

    assert.strictEqual(count, 1);

    app2.service("todo").off("created", incrementCount);
  });

  it("unregisters event listeners when amqp connection is closed", async () => {
    const original = { test: "data" };

    let count = 0;

    const incrementCount = () => {
      count++;
    };

    app2.service("todo").on("created", incrementCount);

    app2.sync.connection.close();

    await app2.sync.connection.connect();

    await app1.service("todo").create(original);

    assert.strictEqual(count, 1);

    app2.service("todo").off("created", incrementCount);
  });