diff --git a/src/pipecat/transports/daily/transport.py b/src/pipecat/transports/daily/transport.py
index fe106ebeb..20a0be29f 100644
--- a/src/pipecat/transports/daily/transport.py
+++ b/src/pipecat/transports/daily/transport.py
@@ -1733,7 +1733,7 @@ class DailyInputTransport(BaseInputTransport):
             message: The message data to send.
             sender: ID of the message sender.
         """
-        await self.broadcast_frame_class(
+        await self.broadcast_frame(
             DailyInputTransportMessageFrame, message=message, participant_id=sender
         )
 
diff --git a/src/pipecat/transports/smallwebrtc/transport.py b/src/pipecat/transports/smallwebrtc/transport.py
index bcc3c8b79..7e76771c4 100644
--- a/src/pipecat/transports/smallwebrtc/transport.py
+++ b/src/pipecat/transports/smallwebrtc/transport.py
@@ -698,7 +698,7 @@ class SmallWebRTCInputTransport(BaseInputTransport):
             message: The application message to process.
         """
         logger.debug(f"Received app message inside SmallWebRTCInputTransport  {message}")
-        await self.broadcast_frame_class(InputTransportMessageFrame, message=message)
+        await self.broadcast_frame(InputTransportMessageFrame, message=message)
 
     # Add this method similar to DailyInputTransport.request_participant_image
     async def request_participant_image(self, frame: UserImageRequestFrame):