Skip to content

Commit 05dddbd

Browse files
Update share consumer method from consume_batch to poll in SoakClient
1 parent 5fb65cb commit 05dddbd

1 file changed

Lines changed: 2 additions & 2 deletions

File tree

tests/soak/soakclient.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -380,9 +380,9 @@ def share_run(self):
380380
next_status = now + self.disprate
381381

382382
try:
383-
messages = self.share_consumer.consume_batch(timeout=1.0)
383+
messages = self.share_consumer.poll(timeout=1.0)
384384
except Exception as ex:
385-
self.logger.error("share: consume_batch exception: {}".format(ex))
385+
self.logger.error("share: poll exception: {}".format(ex))
386386
self.share_err_cnt += 1
387387
self.incr_counter("consumer.error", 1)
388388
continue

0 commit comments

Comments
 (0)