Changeset View
Changeset View
Standalone View
Standalone View
swh/journal/client.py
Show First 20 Lines • Show All 163 Lines • ▼ Show 20 Lines | def process(self, worker_fn): | ||||
if nb_messages >= self.max_messages: | if nb_messages >= self.max_messages: | ||||
break | break | ||||
if nb_messages: | if nb_messages: | ||||
worker_fn(dict(objects)) | worker_fn(dict(objects)) | ||||
self.consumer.commit() | self.consumer.commit() | ||||
return nb_messages | return nb_messages | ||||
def close(self): | |||||
self.consumer.close() |