From 2032a505ba4ee2fc73404e6d2fafc2967bb06bd2 Mon Sep 17 00:00:00 2001
From: Lopez Daniel <daniel.lopez@kapsch.net>
Date: Sun, 9 Jun 2024 11:45:20 +0200
Subject: [PATCH] fix: added schema to messages in batch_receive method

---
 pulsar/__init__.py | 1 +
 1 file changed, 1 insertion(+)

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