diff --git a/rally-jobs/rally-zaqar.yaml b/rally-jobs/rally-zaqar.yaml index 2009d827..c9e2332b 100644 --- a/rally-jobs/rally-zaqar.yaml +++ b/rally-jobs/rally-zaqar.yaml @@ -10,3 +10,17 @@ sla: failure_rate: max: 0 + + ZaqarBasic.producer_consumer: + - + args: + name_length: 10 + min_msg_count: 50 + max_msg_count: 200 + runner: + type: "constant" + times: 100 + concurrency: 10 + sla: + failure_rate: + max: 0 diff --git a/tests/unit/fakes.py b/tests/unit/fakes.py index ac52dbe4..fea30805 100644 --- a/tests/unit/fakes.py +++ b/tests/unit/fakes.py @@ -248,10 +248,13 @@ class FakeQueue(FakeResource): self.queue_name = name self.messages = FakeMessagesManager(name) - def post_message(self, messages): + def post(self, messages): for msg in messages: self.messages.create(**msg) + def messages(self): + return self.messages.list() + class FakeDbInstance(FakeResource): pass