[client] Prefetch count 1 for enrichment

SamuelHassine · SamuelHassine · commit d2e0df25423e · 2023-10-27T13:33:43.000+02:00
diff --git a/pycti/connector/opencti_connector_helper.py b/pycti/connector/opencti_connector_helper.py
@@ -307,6 +307,7 @@ def run(self) -> None:
                 )
                 self.pika_connection = pika.BlockingConnection(self.pika_parameters)
                 self.channel = self.pika_connection.channel()
+                self.channel.basic_qos(prefetch_count=1)
                 assert self.channel is not None
                 self.channel.basic_consume(
                     queue=self.queue_name, on_message_callback=self._process_message

Original file line number	Diff line number	Diff line change
`@@ -307,6 +307,7 @@ def run(self) -> None:`
`307`	`307`	`)`
`308`	`308`	`self.pika_connection = pika.BlockingConnection(self.pika_parameters)`
`309`	`309`	`self.channel = self.pika_connection.channel()`
	`310`	`+ self.channel.basic_qos(prefetch_count=1)`
`310`	`311`	`assert self.channel is not None`
`311`	`312`	`self.channel.basic_consume(`
`312`	`313`	`queue=self.queue_name, on_message_callback=self._process_message`