diff --git a/engine/text_stream.py b/engine/text_stream.py
index e2e997e..ea6dcbd 100644
--- a/engine/text_stream.py
+++ b/engine/text_stream.py
@@ -6,7 +6,7 @@ from pipecat.frames.frames import (
     LLMFullResponseEndFrame,
     LLMFullResponseStartFrame,
     LLMTextFrame,
-    OutputTransportMessageUrgentFrame,
+    OutputTransportMessageFrame,
     TTSSpeakFrame,
 )
 from pipecat.processors.frame_processor import FrameDirection, FrameProcessor
@@ -38,24 +38,29 @@ class ProductTextStreamProcessor(FrameProcessor):
         await super().process_frame(frame, direction)
 
         if isinstance(frame, LLMFullResponseStartFrame):
+            await self.push_frame(frame, direction)
             await self._start_turn()
         elif isinstance(frame, LLMTextFrame):
+            await self.push_frame(frame, direction)
             if frame.text:
                 await self._delta(frame.text)
         elif isinstance(frame, LLMFullResponseEndFrame):
+            await self.push_frame(frame, direction)
             await self._end_turn(interrupted=False)
         elif isinstance(frame, InterruptionFrame):
+            await self.push_frame(frame, direction)
             await self._end_turn(interrupted=True)
         elif isinstance(frame, TTSSpeakFrame):
             # Fixed-text / direct-speech path: there's no LLM cycle, so
             # synthesize one started/delta/final sequence for the spoken text.
             text = frame.text or ""
+            await self.push_frame(frame, direction)
             await self._start_turn()
             if text:
                 await self._delta(text)
             await self._end_turn(interrupted=False)
-
-        await self.push_frame(frame, direction)
+        else:
+            await self.push_frame(frame, direction)
 
     async def _start_turn(self) -> None:
         if self._turn_active:
@@ -86,7 +91,7 @@ class ProductTextStreamProcessor(FrameProcessor):
 
     async def _emit(self, event_type: str, **payload: object) -> None:
         await self.push_frame(
-            OutputTransportMessageUrgentFrame(
+            OutputTransportMessageFrame(
                 message={"type": event_type, **payload},
             ),
             FrameDirection.DOWNSTREAM,