diff --git a/src/Appwrite/Messaging/Adapter/Realtime.php b/src/Appwrite/Messaging/Adapter/Realtime.php
index be83c68e4..9a3930b4c 100644
--- a/src/Appwrite/Messaging/Adapter/Realtime.php
+++ b/src/Appwrite/Messaging/Adapter/Realtime.php
@@ -275,6 +275,19 @@ class Realtime extends Adapter
                 $channels[] = 'teams.' . $payload->getId();
                 $roles = ['team:' . $payload->getId()];
 
+                break;
+            case strpos($event, 'database.collections.') === 0:
+                $channels[] = 'collections';
+                $channels[] = 'collections.' . $payload->getId();
+                $roles = $payload->getRead();
+
+                break;
+            case strpos($event, 'database.attributes.') === 0:
+            case strpos($event, 'database.indexes.') === 0:
+                $channels[] = 'console';
+                $projectId = 'console';
+                $roles = ['team:' . $project->getAttribute('teamId')];
+
                 break;
             case strpos($event, 'database.documents.') === 0:
                 $channels[] = 'documents';