diff --git a/resolvers/inbox/messages.py b/resolvers/inbox/messages.py
index 36cde3ac..de05b2e6 100644
--- a/resolvers/inbox/messages.py
+++ b/resolvers/inbox/messages.py
@@ -140,7 +140,7 @@ async def mark_as_read(_, info, chat_id: str, messages: [int]):
     }
 
 
-@subscription.source("newMessage")
+@subscription.source("newMessages")
 @login_required
 async def message_generator(obj, info):
     print(f"[resolvers.messages] generator {info}")
@@ -174,4 +174,3 @@ async def messages_generator_by_user(user_id):
             yield msg
     finally:
         await MessagesStorage.remove_chat(following_chat)
-
diff --git a/schema.graphql b/schema.graphql
index 35f4663d..0bc4e096 100644
--- a/schema.graphql
+++ b/schema.graphql
@@ -305,7 +305,7 @@ type Query {
 ############################################ Subscription
 
 type Subscription {
-  newMessage(chats: [Int!]): Message!
+  newMessages: Message!
   onlineUpdated: [User!]!
   shoutUpdated: Shout!
   userUpdated: User!
@@ -507,6 +507,7 @@ type Message {
   id: Int!
   replyTo: String
   updatedAt: Int
+  seen: Boolean
 }
 
 type Chat {
diff --git a/services/inbox/helpers.py b/services/inbox/helpers.py
index 56223160..d8791218 100644
--- a/services/inbox/helpers.py
+++ b/services/inbox/helpers.py
@@ -3,7 +3,7 @@ import asyncio
 
 class MessageResult:
     def __init__(self, status, message):
-        self.status = status
+        self.seen = status
         self.message = message