diff options
| author | Zuul <zuul@review.opendev.org> | 2019-04-29 22:36:42 +0000 |
|---|---|---|
| committer | Gerrit Code Review <review@openstack.org> | 2019-04-29 22:36:42 +0000 |
| commit | 558fc5f4e8aa4b8553ee7522d21cc1583e10a849 (patch) | |
| tree | 3dad4066c6c272e0f8bf9c2c4b81e17e9b191421 /tools | |
| parent | 433d34ed4149ad2dcbb860b07754dea25cb43407 (diff) | |
| parent | 0ad4a204b385273b671327028d30133725c6174e (diff) | |
| download | oslo-messaging-558fc5f4e8aa4b8553ee7522d21cc1583e10a849.tar.gz | |
Merge "Consider the topic parameter as an array in client-notify"
Diffstat (limited to 'tools')
| -rwxr-xr-x | tools/simulator.py | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/tools/simulator.py b/tools/simulator.py index 0a9cd5e..fd4461d 100755 --- a/tools/simulator.py +++ b/tools/simulator.py @@ -549,7 +549,7 @@ def spawn_notify_clients(threads, topic, transport, message_count, wait_after_msg, timeout, duration): p = eventlet.GreenPool(size=threads) for i in six.moves.range(threads): - client_builder = functools.partial(NotifyClient, i, transport, topic, + client_builder = functools.partial(NotifyClient, i, transport, [topic], wait_after_msg) p.spawn_n(send_messages, i, client_builder, message_count, duration) p.waitall() |