Skip to content

Commit

Permalink
Revert "Reland "Ensure that sites can still communicate after me...""
Browse files Browse the repository at this point in the history
This reverts commit 99bc031.

Change-Id: I75be4965d1256ad17ea05f130f560b6319ba64a9
  • Loading branch information
mo-ki committed Dec 12, 2024
1 parent 07e3b8c commit baa7374
Showing 1 changed file with 0 additions and 21 deletions.
21 changes: 0 additions & 21 deletions tests/composition/message_broker/test_message_broker.py
Original file line number Diff line number Diff line change
Expand Up @@ -12,7 +12,6 @@
from tests.testlib.site import Site

from tests.composition.message_broker.utils import (
assert_message_exchange_not_working,
assert_message_exchange_working,
broker_pong,
broker_stopped,
Expand Down Expand Up @@ -102,23 +101,3 @@ def test_message_broker_remote_remote_p2p(
broker_stopped(central_site),
):
check_broker_ping(remote_site_2, remote_site.id)

def test_rabbitmq_port_change(self, central_site: Site, remote_site: Site) -> None:
"""Ensure that sites can still communicate after the message broker port is changed"""
site_connection = central_site.openapi.show_site(remote_site.id)["extensions"]
site_connection_port = int(
site_connection["configuration_connection"]["message_broker_port"]
)
assert site_connection_port == remote_site.message_broker_port
next_port = _next_free_port(remote_site, "RABBITMQ_PORT", str(site_connection_port + 1))

remote_site.set_config("RABBITMQ_PORT", str(next_port), with_restart=True)

site_connection["configuration_connection"]["message_broker_port"] = str(next_port)
central_site.openapi.update_site(remote_site.id, site_connection)

# ensure changes are not in effect before activated
assert_message_exchange_not_working(central_site, remote_site)
central_site.openapi.activate_changes_and_wait_for_completion()

assert_message_exchange_working(central_site, remote_site)

0 comments on commit baa7374

Please sign in to comment.