diff --git a/src/rabbitmq_handler.py b/src/rabbitmq_handler.py
index 5d2b19f..60d3a9d 100644
--- a/src/rabbitmq_handler.py
+++ b/src/rabbitmq_handler.py
@@ -72,7 +72,7 @@ class RabbitMQConsumer:
 		await queue.bind(self.exchange, routing_key=f"{self.pull_routing_prefix}.{user_id}")
 		return queue
 		
-	async def fetch_messages(self, user_id: int, max_messages: int = 100) -> list[dict]:
+	async def fetch_messages(self, user_id: int, max_messages: int = 10) -> list[dict]:
 		"""Drain up to max_messages queued messages for this user and return their
 		decoded JSON bodies.