diff --git a/src/Appwrite/Platform/Workers/Messaging.php b/src/Appwrite/Platform/Workers/Messaging.php
index d0e47d1133..3267a9034e 100644
--- a/src/Appwrite/Platform/Workers/Messaging.php
+++ b/src/Appwrite/Platform/Workers/Messaging.php
@@ -97,7 +97,7 @@ class Messaging extends Action
         if (\count($topicIds) > 0) {
             $topics = $dbForProject->find('topics', [
                 Query::equal('$id', $topicIds),
-                Query::limit($topicIds)
+                Query::limit(\count($topicIds)),
             ]);
             foreach ($topics as $topic) {
                 $targets = \array_filter($topic->getAttribute('targets'), fn(Document $target) =>
@@ -109,7 +109,7 @@ class Messaging extends Action
         if (\count($userIds) > 0) {
             $users = $dbForProject->find('users', [
                 Query::equal('$id', $userIds),
-                Query::limit($userIds)
+                Query::limit(\count($userIds)),
             ]);
             foreach ($users as $user) {
                 $targets = \array_filter($user->getAttribute('targets'), fn(Document $target) =>
@@ -121,7 +121,7 @@ class Messaging extends Action
         if (\count($targetIds) > 0) {
             $targets = $dbForProject->find('targets', [
                 Query::equal('$id', $targetIds),
-                Query::limit($targetIds)
+                Query::limit(\count($targetIds)),
             ]);
             $recipients = \array_merge($recipients, $targets);
         }