diff --git a/CHANGELOG.md b/CHANGELOG.md
index fcaae4cb3..b19c64876 100644
--- a/CHANGELOG.md
+++ b/CHANGELOG.md
@@ -9,6 +9,8 @@ and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0
 
 ### Added
 
+- Exposed Daily transport `on_app_message` event.
+
 - Added Daily transport `on_call_state_updated` event.
 
 - Added Daily transport `start_recording()`, `stop_recording` and
diff --git a/src/pipecat/transports/services/daily.py b/src/pipecat/transports/services/daily.py
index 6d5006e9d..5491882f2 100644
--- a/src/pipecat/transports/services/daily.py
+++ b/src/pipecat/transports/services/daily.py
@@ -671,6 +671,7 @@ class DailyTransport(BaseTransport):
         # these handlers.
         self._register_event_handler("on_joined")
         self._register_event_handler("on_left")
+        self._register_event_handler("on_app_message")
         self._register_event_handler("on_call_state_updated")
         self._register_event_handler("on_dialout_connected")
         self._register_event_handler("on_dialout_stopped")
@@ -752,6 +753,7 @@ class DailyTransport(BaseTransport):
     def _on_app_message(self, message: Any, sender: str):
         if self._input:
             self._input.push_app_message(message, sender)
+        self.on_app_message(message, sender)
 
     def _on_call_state_updated(self, state: str):
         self.on_call_state_updated(state)
@@ -828,6 +830,9 @@ class DailyTransport(BaseTransport):
     def on_left(self):
         pass
 
+    def on_app_message(self, message, sender):
+        pass
+
     def on_call_state_updated(self, state):
         pass