async def METHOD_NAME(mocker, caplog):
    mocker.patch("server.message_queue_service.config.MQ_VHOST", "bad_vhost")
    service = MessageQueueService()
    await service.initialize()
    assert any("Incorrect vhost?" in msg for msg in caplog.messages)