Changeset View
Changeset View
Standalone View
Standalone View
swh/journal/tests/utils.py
| Show First 20 Lines • Show All 66 Lines • ▼ Show 20 Lines | |||||
| class MockedJournalClient(JournalClient): | class MockedJournalClient(JournalClient): | ||||
| def __init__(self, queue, object_types=ACCEPTED_OBJECT_TYPES): | def __init__(self, queue, object_types=ACCEPTED_OBJECT_TYPES): | ||||
| self._object_types = object_types | self._object_types = object_types | ||||
| self.consumer = MockedKafkaConsumer(queue) | self.consumer = MockedKafkaConsumer(queue) | ||||
| self.process_timeout = 0 | self.process_timeout = 0 | ||||
| self.max_messages = 0 | self.max_messages = 0 | ||||
| self.value_deserializer = kafka_to_value | self.value_deserializer = kafka_to_value | ||||
| self.stop_on_eof = False | |||||