diff --git a/src/rabbitmq_handler.py b/src/rabbitmq_handler.py
index a356189..9819480 100644
--- a/src/rabbitmq_handler.py
+++ b/src/rabbitmq_handler.py
@@ -63,7 +63,7 @@ class RabbitMQProducer:
 					mandatory=True
 				)
 				logger.debug(f"[RabbitMQ] Successfully published to notify.user.{routing_key}")
-			except (AMQPException, ConnectionError, OSError) as e:
+			except (AMQPException, OSError) as e:
 				logger.warning(f"[RabbitMQ] Publish failed, requeuing message: {e}", exc_info=True)
 				await asyncio.sleep(2)
 				await self._queue.put((routing_key, message))