diff --git a/src/pipecat/transports/network/small_webrtc.py b/src/pipecat/transports/network/small_webrtc.py
index fdda9533d..987c412fd 100644
--- a/src/pipecat/transports/network/small_webrtc.py
+++ b/src/pipecat/transports/network/small_webrtc.py
@@ -172,7 +172,7 @@ class SmallWebRTCClient:
             logger.debug("Client connection closed.")
             await self._handle_client_closed()
 
-        @self._webrtc_connection.event_handler("appMessage")
+        @self._webrtc_connection.event_handler("app-message")
         async def on_app_message(connection: SmallWebRTCConnection, message: Any):
             await self._handle_app_message(message)
 
diff --git a/src/pipecat/transports/network/webrtc_connection.py b/src/pipecat/transports/network/webrtc_connection.py
index 840126c23..671ff6622 100644
--- a/src/pipecat/transports/network/webrtc_connection.py
+++ b/src/pipecat/transports/network/webrtc_connection.py
@@ -40,7 +40,7 @@ class SmallWebRTCConnection(BaseObject):
 
         # Register supported handlers. The user will only be able to register
         # these handlers.
-        self._register_event_handler("appMessage")
+        self._register_event_handler("app-message")
         self._register_event_handler("track-started")
         self._register_event_handler("track-ended")
         # connection states
@@ -86,7 +86,7 @@ class SmallWebRTCConnection(BaseObject):
                         self._last_received_time = time.time()
                     else:
                         json_message = json.loads(message)
-                        await self._call_event_handler("appMessage", json_message)
+                        await self._call_event_handler("app-message", json_message)
                 except Exception as e:
                     logger.exception(f"Error parsing JSON message {message}, {e}")