Skip to content

Commit 1443f7a

Browse files
committed
Add RabbitMQ monitor to debug test_storage_rabbitmq
1 parent 442cad8 commit 1443f7a

File tree

2 files changed

+267
-157
lines changed

2 files changed

+267
-157
lines changed

tests/integration/helpers/cluster.py

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -2406,6 +2406,9 @@ def reset_rabbitmq(self, timeout=120):
24062406
run_rabbitmqctl(self.rabbitmq_docker_id, self.rabbitmq_cookie, "reset", timeout)
24072407
self.start_rabbitmq_app()
24082408

2409+
def run_rabbitmqctl(self, command):
2410+
run_rabbitmqctl(self.rabbitmq_docker_id, self.rabbitmq_cookie, command)
2411+
24092412
def wait_nats_is_available(self, max_retries=5):
24102413
retries = 0
24112414
while True:

0 commit comments

Comments
 (0)