Only push binary data to aiopika (Fixes #1513)

miguelgrinberg · miguelgrinberg · commit 967c18455b98 · 2025-10-28T20:12:05.000Z
diff --git a/src/socketio/async_aiopika_manager.py b/src/socketio/async_aiopika_manager.py
@@ -82,7 +82,7 @@ async def _publish(self, data):
             try:
                 await self.publisher_exchange.publish(
                     aio_pika.Message(
-                        body=json.dumps(data),
+                        body=json.dumps(data).encode(),
                         delivery_mode=aio_pika.DeliveryMode.PERSISTENT
                     ), routing_key='*',
                 )

Original file line number	Diff line number	Diff line change
`@@ -82,7 +82,7 @@ async def _publish(self, data):`
`82`	`82`	`try:`
`83`	`83`	`await self.publisher_exchange.publish(`
`84`	`84`	`aio_pika.Message(`
`85`		`- body=json.dumps(data),`
	`85`	`+ body=json.dumps(data).encode(),`
`86`	`86`	`delivery_mode=aio_pika.DeliveryMode.PERSISTENT`
`87`	`87`	`), routing_key='*',`
`88`	`88`	`)`