diff --git a/src/modules/stream_notifications/tasks.py b/src/modules/stream_notifications/tasks.py
index 1841199..8a8f4ae 100644
--- a/src/modules/stream_notifications/tasks.py
+++ b/src/modules/stream_notifications/tasks.py
@@ -77,7 +77,7 @@ async def check_streams_states():
 
 
 @broker.task(
-    "stream_notifications.twitch.on_message",
+    "stream_notifications.on_message",
     retry_on_error=True
 )
 async def on_message(event: MessageEvent):