diff --git a/packages/jupyter-ai/jupyter_ai/reply_processor.py b/packages/jupyter-ai/jupyter_ai/reply_processor.py
index 4ff4ed9fe..3df2bfb71 100644
--- a/packages/jupyter-ai/jupyter_ai/reply_processor.py
+++ b/packages/jupyter-ai/jupyter_ai/reply_processor.py
@@ -23,7 +23,4 @@ def process(self, message):
 
     async def start(self):
         while True:
-            if not self.queue.empty():
-                self.process(await self.queue.get_async())
-            
-            await asyncio.sleep(5)
+            self.process(await self.queue.get_async())