diff --git a/src/pipecat/transports/services/daily.py b/src/pipecat/transports/services/daily.py
index 7b0cd6c00..a5936e80a 100644
--- a/src/pipecat/transports/services/daily.py
+++ b/src/pipecat/transports/services/daily.py
@@ -723,7 +723,7 @@ class DailyInputTransport(BaseInputTransport):
         await self.push_frame(frame)
 
     async def push_app_message(self, message: Any, sender: str):
-        frame = DailyTransportMessageFrame(message=message, participant_id=sender)
+        frame = DailyTransportMessageUrgentFrame(message=message, participant_id=sender)
         await self.push_frame(frame)
 
     #
diff --git a/src/pipecat/transports/services/livekit.py b/src/pipecat/transports/services/livekit.py
index 5d4fbdd6c..6c99f6a66 100644
--- a/src/pipecat/transports/services/livekit.py
+++ b/src/pipecat/transports/services/livekit.py
@@ -342,7 +342,7 @@ class LiveKitInputTransport(BaseInputTransport):
         return self._vad_analyzer
 
     async def push_app_message(self, message: Any, sender: str):
-        frame = LiveKitTransportMessageFrame(message=message, participant_id=sender)
+        frame = LiveKitTransportMessageUrgentFrame(message=message, participant_id=sender)
         await self.push_frame(frame)
 
     async def _audio_in_task_handler(self):