diff --git a/pulsar/__init__.py b/pulsar/__init__.py
index fad33cd..1b2cc68 100644
--- a/pulsar/__init__.py
+++ b/pulsar/__init__.py
@@ -1481,6 +1481,7 @@ def batch_receive(self):
         for msg in msgs:
             m = Message()
             m._message = msg
+            m._schema = self._schema
             messages.append(m)
         return messages